fix: fix l0 compaction may miss some sealed segments

issue: milvus-io#33955 Signed-off-by: sunby <sunbingyi1992@gmail.com>
sunby · Jun 19, 2024 · f4b2b85 · f4b2b85
1 parent 1216a4b
commit f4b2b85
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 {