diff --git a/internal/datacoord/compaction_task_l0.go b/internal/datacoord/compaction_task_l0.go index a18a14cac4695..fdadfd1371a83 100644 --- a/internal/datacoord/compaction_task_l0.go +++ b/internal/datacoord/compaction_task_l0.go @@ -250,7 +250,7 @@ func (t *l0CompactionTask) BuildCompactionRequest() (*datapb.CompactionPlan, err //!info.isCompacting && !info.GetIsImporting() && info.GetLevel() != datapb.SegmentLevel_L0 && - info.GetDmlPosition().GetTimestamp() < t.GetPos().GetTimestamp() + info.GetStartPosition().GetTimestamp() < t.GetPos().GetTimestamp() })) if len(sealedSegments) == 0 {