follow your heart .jerqi

zuston · Aug 16, 2023 · a620c06 · a620c06
1 parent d69c780
commit a620c06
Showing 1 changed file with 8 additions and 8 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
@@ -408,15 +408,15 @@ public List<AddBlockEvent> buildBlockEvents(List<ShuffleBlockInfo> shuffleBlockI
  + totalSize
  + " bytes");
  // Use final temporary variables for closures
- final long _memoryUsed = memoryUsed;
- final List<ShuffleBlockInfo> _blocks = shuffleBlockInfosPerEvent;
+ final long memoryUsedTemp = memoryUsed;
+ final List<ShuffleBlockInfo> shuffleBlocksTemp = shuffleBlockInfosPerEvent;
  events.add(
  new AddBlockEvent(
  taskId,
  shuffleBlockInfosPerEvent,
  () -> {
- freeAllocatedMemory(_memoryUsed);
- _blocks.stream().forEach(x -> x.getData().release());
+ freeAllocatedMemory(memoryUsedTemp);
+ shuffleBlocksTemp.stream().forEach(x -> x.getData().release());
  }));
  shuffleBlockInfosPerEvent = Lists.newArrayList();
  totalSize = 0;
@@ -431,15 +431,15 @@ public List<AddBlockEvent> buildBlockEvents(List<ShuffleBlockInfo> shuffleBlockI
  + totalSize
  + " bytes");
  // Use final temporary variables for closures
- final long _memoryUsed = memoryUsed;
- final List<ShuffleBlockInfo> _blocks = shuffleBlockInfosPerEvent;
+ final long memoryUsedTemp = memoryUsed;
+ final List<ShuffleBlockInfo> shuffleBlocksTemp = shuffleBlockInfosPerEvent;
  events.add(
  new AddBlockEvent(
  taskId,
  shuffleBlockInfosPerEvent,
  () -> {
- freeAllocatedMemory(_memoryUsed);
- _blocks.stream().forEach(x -> x.getData().release());
+ freeAllocatedMemory(memoryUsedTemp);
+ shuffleBlocksTemp.stream().forEach(x -> x.getData().release());
  }));
  }
  return events;