From 893caee467d3aabe298e0cc8730c52b17ffa2273 Mon Sep 17 00:00:00 2001
From: "yihao.dai" <yihao.dai@zilliz.com>
Date: Sun, 2 Mar 2025 16:52:10 +0800
Subject: [PATCH] fix: [2.5] Fix task delta cache data race (#40262)

issue: https://github.com/milvus-io/milvus/issues/40258

pr: https://github.com/milvus-io/milvus/pull/40259

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
---
 internal/querycoordv2/task/scheduler.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/internal/querycoordv2/task/scheduler.go b/internal/querycoordv2/task/scheduler.go
index 2c8f713f3d..46b353325a 100644
--- 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()
 }