Fix endless appending sids (#22977)

See also: #22976 Signed-off-by: yangxuan <xuan.yang@zilliz.com>
2023-03-24 18:00:03 +08:00 · 2023-03-24 18:00:03 +08:00 · da58ba6a49
parent 8aebc6f3b7
commit da58ba6a49
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
@ -99,10 +99,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()