From 85ade98ebaaf1830b0e9c7beb5f7e6e763226499 Mon Sep 17 00:00:00 2001 From: "cai.zhang" Date: Fri, 13 Dec 2024 10:12:49 +0800 Subject: [PATCH] fix: [2.4]Fix sorting buffer in clustering compaction (#38418) issue: #28410 master pr: #38417 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 1a8cf7101e0a0..1af8febfcf032 100644 --- a/internal/datanode/compaction/clustering_compactor.go +++ b/internal/datanode/compaction/clustering_compactor.go @@ -806,7 +806,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))