From 9cd6dbcbc9c0fdebd8f3b68150ea810b7e35de62 Mon Sep 17 00:00:00 2001 From: "cai.zhang" Date: Fri, 26 Jul 2024 11:33:40 +0800 Subject: [PATCH] fix: [cherry-pick] Fix bug for block clustering compaction (#35021) issue: #34703 master pr: #35019 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 a1f95ff5aa..c6ea167ea5 100644 --- a/internal/datanode/compaction/clustering_compactor.go +++ b/internal/datanode/compaction/clustering_compactor.go @@ -711,8 +711,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)