From 669a109f2ddcfedff6f07e211174d1c6b693b364 Mon Sep 17 00:00:00 2001 From: Bingyi Sun Date: Fri, 21 Jun 2024 16:52:15 +0800 Subject: [PATCH] fix: fix l0 compaction may miss some sealed segments (#33980) issue: https://github.com/milvus-io/milvus/issues/33955 Signed-off-by: sunby --- internal/datacoord/compaction_task_l0.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/datacoord/compaction_task_l0.go b/internal/datacoord/compaction_task_l0.go index a18a14cac469..fdadfd1371a8 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 {