fix

apache · May 30, 2024 · 42e6946 · 42e6946
1 parent cb276ea
commit 42e6946
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/client-spark/common/src/main/java/org/apache/spark/shuffle/writer/WriteBufferManager.java b/client-spark/common/src/main/java/org/apache/spark/shuffle/writer/WriteBufferManager.java
@@ -335,8 +335,7 @@ public synchronized List<ShuffleBlockInfo> clear(double bufferSpillRatio) {
     List<Integer> partitionList = new ArrayList(buffers.keySet());
     if (Double.compare(bufferSpillRatio, 1.0) < 0) {
       partitionList.sort(
-          Comparator.comparingInt(
-                  o -> buffers.get(o) == null ? 0 : buffers.get(o).getMemoryUsed())
+          Comparator.comparingInt(o -> buffers.get(o) == null ? 0 : buffers.get(o).getMemoryUsed())
               .reversed());
       targetSpillSize = (long) ((getUsedBytes() - getInSendListBytes()) * bufferSpillRatio);
     }