From f4b2b8596adb3cb50de45cc13baaa2c5dcebddc3 Mon Sep 17 00:00:00 2001 From: sunby Date: Wed, 19 Jun 2024 16:19:21 +0800 Subject: [PATCH] fix: fix l0 compaction may miss some sealed segments 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 {