fix: Deadlock in compaction handler (milvus-io#37868)

issue: milvus-io#37803 Signed-off-by: Wei Liu <[email protected]>
congqixia · Nov 21, 2024 · 2159526 · 2159526
1 parent 70e6a00
commit 2159526
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/internal/datacoord/compaction.go b/internal/datacoord/compaction.go
@@ -303,6 +303,7 @@ func (c *compactionPlanHandler) schedule() []CompactionTask {
 		c.executingGuard.Lock()
 		c.executingTasks[t.GetTaskProto().GetPlanID()] = t
 		if len(c.executingTasks) >= parallelism {
+			c.executingGuard.Unlock()
 			break // 2. the parallelism of running tasks is reached
 		}
 		c.executingGuard.Unlock()