diff --git a/internal/datanode/flow_graph_time_ticker.go b/internal/datanode/flow_graph_time_ticker.go
index 7c4302b67f..039a7c07cb 100644
--- a/internal/datanode/flow_graph_time_ticker.go
+++ b/internal/datanode/flow_graph_time_ticker.go
@@ -64,10 +64,10 @@ func newUniqueMergedTimeTickerSender(send sendTimeTick) *mergedTimeTickerSender
 func getOrCreateMergedTimeTickerSender(send sendTimeTick) *mergedTimeTickerSender {
 	getUniqueMergedTimeTickerSender.Do(func() {
 		uniqueMergedTimeTickerSender = newUniqueMergedTimeTickerSender(send)
+		uniqueMergedTimeTickerSender.wg.Add(2)
+		go uniqueMergedTimeTickerSender.tick()
+		go uniqueMergedTimeTickerSender.work()
 	})
-	uniqueMergedTimeTickerSender.wg.Add(2)
-	go uniqueMergedTimeTickerSender.tick()
-	go uniqueMergedTimeTickerSender.work()
 	return uniqueMergedTimeTickerSender
 }