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