diff --git a/internal/datanode/flow_graph_time_ticker.go b/internal/datanode/flow_graph_time_ticker.go
index a05b407091..255db2915a 100644
--- a/internal/datanode/flow_graph_time_ticker.go
+++ b/internal/datanode/flow_graph_time_ticker.go
@@ -97,10 +97,12 @@ func (mt *mergedTimeTickerSender) isClosed() bool {
 
 func (mt *mergedTimeTickerSender) work() {
 	defer mt.wg.Done()
-	var sids []int64
-	var isDiffTs bool
 	lastTs := uint64(0)
 	for {
+		var (
+			isDiffTs bool
+			sids     []int64
+		)
 		mt.cond.L.Lock()
 		if mt.isClosed() {
 			mt.cond.L.Unlock()