fix: fix l0 compaction may miss some sealed segments (#33980)

issue: #33955 Signed-off-by: sunby <[email protected]>
milvus-io · Jun 21, 2024 · 622be36 · 622be36
1 parent 958ecd5
commit 622be36
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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 {