From 51c414c0c06fa813040bbabe60d44f14c49a7cd5 Mon Sep 17 00:00:00 2001 From: Xiaofan <83447078+xiaofan-luan@users.noreply.github.com> Date: Sat, 25 Mar 2023 14:55:57 +0800 Subject: [PATCH] Pick Fix endless appending sids (#22989) Signed-off-by: xiaofan-luan --- internal/datanode/flow_graph_time_ticker.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) 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()