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>
This commit is contained in:
yihao.dai 2025-07-24 14:53:34 +08:00 committed by GitHub
parent 3d8f728091
commit 804a7692a6
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -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