improve range based size

wg1026688210 · Jan 29, 2024 · e2a96b6 · e2a96b6
1 parent dceed11
commit e2a96b6
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/docs/layouts/shortcodes/generated/core_configuration.html b/docs/layouts/shortcodes/generated/core_configuration.html
@@ -575,12 +575,6 @@
             <td>Duration</td>
             <td>The maximum time of completed snapshots to retain.</td>
         </tr>
-        <tr>
-            <td><h5>snapshot.watermark-idle-timeout</h5></td>
-            <td style="word-wrap: break-word;">(none)</td>
-            <td>Duration</td>
-            <td>In watermarking, if a source remains idle beyond the specified timeout duration, it triggers snapshot advancement and facilitates tag creation.</td>
-        </tr>
         <tr>
             <td><h5>sort-compaction.range-strategy</h5></td>
             <td style="word-wrap: break-word;">QUANTITY</td>
@@ -666,6 +660,12 @@
             <td>Integer</td>
             <td>The maximum number of tags to retain.</td>
         </tr>
+        <tr>
+            <td><h5>snapshot.watermark-idle-timeout</h5></td>
+            <td style="word-wrap: break-word;">(none)</td>
+            <td>Duration</td>
+            <td>In watermarking, if a source remains idle beyond the specified timeout duration, it triggers snapshot advancement and facilitates tag creation.</td>
+        </tr>
         <tr>
             <td><h5>tag.period-formatter</h5></td>
             <td style="word-wrap: break-word;">with_dashes</td>

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;
                 }