From ea13b97b6a638d05941d6a511dd8e018d26bbf14 Mon Sep 17 00:00:00 2001 From: "cai.zhang" Date: Fri, 26 Jul 2024 11:33:58 +0800 Subject: [PATCH] fix: Fix bug for block clustering compaction (#35019) issue: #34703 Signed-off-by: Cai Zhang --- internal/datanode/compaction/clustering_compactor.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/datanode/compaction/clustering_compactor.go b/internal/datanode/compaction/clustering_compactor.go index b92902f4a1..6071aaf5a1 100644 --- a/internal/datanode/compaction/clustering_compactor.go +++ b/internal/datanode/compaction/clustering_compactor.go @@ -714,8 +714,8 @@ func (t *clusteringCompactionTask) backgroundFlush(ctx context.Context) { if signal.done { t.doneChan <- struct{}{} } else if signal.writer == nil { - err = t.flushLargestBuffers(ctx) t.hasSignal.Store(false) + err = t.flushLargestBuffers(ctx) } else { future := t.flushPool.Submit(func() (any, error) { err := t.flushBinlog(ctx, t.clusterBuffers[signal.id], signal.writer, signal.pack)