fix: Fix task delta cache data race (#40259)

issue: #40258 Signed-off-by: bigsheeper <[email protected]>
milvus-io · Mar 2, 2025 · c368113 · c368113
1 parent 2ff657f
commit c368113
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/internal/querycoordv2/task/scheduler.go b/internal/querycoordv2/task/scheduler.go
@@ -246,8 +246,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()
 }