Pick Fix endless appending sids (#22989)

Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>
2023-03-25 14:55:57 +08:00 · 2023-03-25 14:55:57 +08:00 · 51c414c0c0
parent f1a389e910
commit 51c414c0c0
1 changed files with 4 additions and 2 deletions
--- 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()