Fix waitNewTSafe not waiting (#10724)

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
2021-10-27 14:22:22 +08:00 · 2021-10-27 14:22:22 +08:00 · 5317c8abab
parent c51155a542
commit 5317c8abab
1 changed files with 2 additions and 0 deletions
--- a/internal/querynode/query_collection.go
+++ b/internal/querynode/query_collection.go
@ -221,6 +221,8 @@ func (q *queryCollection) waitNewTSafe() (Timestamp, error) {
 	for !q.tSafeUpdate {
 		q.watcherCond.Wait()
 	}
+	q.tSafeUpdate = false
+	q.watcherCond.Broadcast()
 	q.watcherCond.L.Unlock()
 	q.tSafeWatchersMu.RLock()
 	defer q.tSafeWatchersMu.RUnlock()