fix: [2.4] Release compaction task lock when return function (#38857)

issue: #38851 master pr: #38856 Signed-off-by: Cai Zhang <[email protected]>
milvus-io · Dec 31, 2024 · c3e26a3 · c3e26a3
1 parent 253860b
commit c3e26a3
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/internal/datacoord/compaction.go b/internal/datacoord/compaction.go
@@ -206,19 +206,18 @@ func (c *compactionPlanHandler) schedule() []CompactionTask {
 		slots       map[int64]int64
 	)
 
-	c.executingGuard.Lock()
-	if len(c.executingTasks) >= parallelism {
-		return selected
-	}
-	c.executingGuard.Unlock()
-
 	l0ChannelExcludes := typeutil.NewSet[string]()
 	mixChannelExcludes := typeutil.NewSet[string]()
 	clusterChannelExcludes := typeutil.NewSet[string]()
 	mixLabelExcludes := typeutil.NewSet[string]()
 	clusterLabelExcludes := typeutil.NewSet[string]()
 
 	c.executingGuard.RLock()
+	if len(c.executingTasks) >= parallelism {
+		c.executingGuard.RUnlock()
+		return selected
+	}
+
 	for _, t := range c.executingTasks {
 		switch t.GetType() {
 		case datapb.CompactionType_Level0DeleteCompaction: