From 418f971d2db2b3860a76c804dfbadf86022db7d9 Mon Sep 17 00:00:00 2001 From: "cai.zhang" Date: Fri, 14 Feb 2025 13:38:15 +0800 Subject: [PATCH] fix: [2.5] ReEnqueue L0 compaction task when preCheck failed (#39871) issue: #39868 master pr: #39870 Signed-off-by: Cai Zhang --- internal/datacoord/compaction.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/internal/datacoord/compaction.go b/internal/datacoord/compaction.go index ac1abf03e1..3707e15cbd 100644 --- a/internal/datacoord/compaction.go +++ b/internal/datacoord/compaction.go @@ -327,6 +327,8 @@ func (c *compactionPlanHandler) schedule() []CompactionTask { // Do not move this check logic outside the lock; it needs to remain mutually exclusive with the stats task. if t.GetTaskProto().GetType() == datapb.CompactionType_Level0DeleteCompaction { if !t.PreparePlan() { + selected = selected[:len(selected)-1] + excluded = append(excluded, t) c.executingGuard.Unlock() continue }