From 804a7692a67b04f1cc2557c99e613e0e015a8e99 Mon Sep 17 00:00:00 2001
From: "yihao.dai" <yihao.dai@zilliz.com>
Date: Thu, 24 Jul 2025 14:53:34 +0800
Subject: [PATCH] fix: Fix delete loss caused by missing mutual exclusion in
 sort compaction (#43540)

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

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
---
 internal/datacoord/compaction_inspector.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/internal/datacoord/compaction_inspector.go b/internal/datacoord/compaction_inspector.go
index d79414336c..86a9e05d9e 100644
--- a/internal/datacoord/compaction_inspector.go
+++ b/internal/datacoord/compaction_inspector.go
@@ -271,7 +271,7 @@ func (c *compactionInspector) schedule() []CompactionTask {
 			}
 			l0ChannelExcludes.Insert(t.GetTaskProto().GetChannel())
 			selected = append(selected, t)
-		case datapb.CompactionType_MixCompaction:
+		case datapb.CompactionType_MixCompaction, datapb.CompactionType_SortCompaction:
 			if l0ChannelExcludes.Contain(t.GetTaskProto().GetChannel()) {
 				excluded = append(excluded, t)
 				continue