fix: [2.4]Fix sorting buffer in clustering compaction (#38418)

issue: #28410 master pr: #38417 Signed-off-by: Cai Zhang <[email protected]>
milvus-io · Dec 13, 2024 · 85ade98 · 85ade98
1 parent 24c8883
commit 85ade98
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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))