From 6ffc57c8dc9bd76111d293fb812d2123770922ac Mon Sep 17 00:00:00 2001 From: "cai.zhang" Date: Fri, 13 Dec 2024 10:12:49 +0800 Subject: [PATCH] fix: Fix sorting buffer in clustering compaction (#38417) issue: #28410 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 0e4541c43e..4c37c81f04 100644 --- a/internal/datanode/compaction/clustering_compactor.go +++ b/internal/datanode/compaction/clustering_compactor.go @@ -857,7 +857,7 @@ func (t *clusteringCompactionTask) flushLargestBuffers(ctx context.Context) erro t.clusterBufferLocks.RUnlock(buffer.id) } sort.Slice(bufferIDs, func(i, j int) bool { - return bufferRowNums[i] > bufferRowNums[j] + return bufferRowNums[bufferIDs[i]] > bufferRowNums[bufferIDs[j]] }) log.Info("start flushLargestBuffers", zap.Ints("bufferIDs", bufferIDs), zap.Int64("currentMemorySize", currentMemorySize))