Make datanode tt interval configurable (#22990)

Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>

internal/datanode/flow_graph_time_ticker.go

@@ -72,13 +72,13 @@ func (mt *mergedTimeTickerSender) bufferTs(ts Timestamp, segmentIDs []int64) {
 func (mt *mergedTimeTickerSender) tick() {
 	defer mt.wg.Done()
 	// this duration might be configuable in the future
-	t := time.NewTicker(time.Millisecond * 100) // 100 millisecond, 1/2 of rootcoord timetick duration
+	t := time.NewTicker(time.Duration(Params.DataNodeCfg.DataNodeTimeTickInterval) * time.Millisecond) // 500 millisecond
 	defer t.Stop()
 	for {
 		select {
 		case <-t.C:
 			mt.cond.L.Lock()
-			mt.cond.Signal() // allow worker to check every 0.1s
+			mt.cond.Signal()
 			mt.cond.L.Unlock()
 		case <-mt.closeCh:
 			return

internal/util/paramtable/component_param.go

@@ -1564,6 +1564,9 @@ type dataNodeConfig struct {
 	// io concurrency to fetch stats logs
 	IOConcurrency int
 
+	// datanote send timetick interval per channel
+	DataNodeTimeTickInterval int
+
 	CreatedTime time.Time
 	UpdatedTime time.Time
 
@@ -1584,6 +1587,7 @@ func (p *dataNodeConfig) init(base *BaseTable) {
 	p.initBinlogMaxSize()
 	p.initSyncPeriod()
 	p.initIOConcurrency()
+	p.initDataNodeTimeTickInterval()
 
 	p.initChannelWatchPath()
 	p.initMemoryForceSyncEnable()
@@ -1645,6 +1649,10 @@ func (p *dataNodeConfig) initIOConcurrency() {
 	p.IOConcurrency = p.Base.ParseIntWithDefault("dataNode.dataSync.ioConcurrency", 10)
 }
 
+func (p *dataNodeConfig) initDataNodeTimeTickInterval() {
+	p.DataNodeTimeTickInterval = p.Base.ParseIntWithDefault("datanode.timetick.interval", 500)
+}
+
 func (p *dataNodeConfig) SetNodeID(id UniqueID) {
 	p.NodeID.Store(id)
 }