fix: [2.5] Fix task delta cache data race (#40262)

issue: #40258 pr: #40259 Signed-off-by: bigsheeper <[email protected]>
milvus-io · Mar 2, 2025 · 893caee · 893caee
1 parent 3f76e1c
commit 893caee
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/internal/querycoordv2/task/scheduler.go b/internal/querycoordv2/task/scheduler.go
@@ -248,8 +248,8 @@ func (etd *ExecutingTaskDelta) printDetailInfos() {
 }
 
 func (etd *ExecutingTaskDelta) Clear() {
-	etd.mu.RLock()
-	defer etd.mu.RUnlock()
+	etd.mu.Lock()
+	defer etd.mu.Unlock()
 	etd.data = make(map[int64]map[int64]int)
 	etd.taskIDRecords.Clear()
 }