Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/19222#discussion_r177692472
--- Diff:
core/src/main/java/org/apache/spark/shuffle/sort/ShuffleInMemorySorter.java ---
@@ -105,13 +104,7 @@ public void reset() {
public void expandPointerArray(LongArray newArray) {
assert(newArray.size() > array.size());
- Platform.copyMemory(
- array.getBaseObject(),
- array.getBaseOffset(),
- newArray.getBaseObject(),
- newArray.getBaseOffset(),
- pos * 8L
- );
+ MemoryBlock.copyMemory(array.memoryBlock(), newArray.memoryBlock(),pos
* 8L);
--- End diff --
space after `,`
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
