improve range based size

apache · Jan 29, 2024 · ed5de85 · ed5de85
1 parent dceed11
commit ed5de85
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/shuffle/RangeShuffle.java b/...flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/shuffle/RangeShuffle.java
@@ -563,7 +563,7 @@ static <T> T[] allocateRangeBaseSize(List<Tuple2<T, Integer>> sampledData, int r
             for (int i = 0; i < boundarySize; i++) {
                 while (currentWeight < stepRange && index < sampeNum) {
                     boundaries[i] = sampledData.get(Math.min(index, sampeNum - 1)).f0;
-                    Integer sampleWeight = sampledData.get(index++).f1;
+                    int sampleWeight = sampledData.get(index++).f1;
                     currentWeight += sampleWeight;
                     restSize -= sampleWeight;
                 }