Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/19222#discussion_r177692646
--- Diff:
core/src/main/java/org/apache/spark/shuffle/sort/ShuffleSortDataFormat.java ---
@@ -60,13 +60,8 @@ public void copyElement(LongArray src, int srcPos,
LongArray dst, int dstPos) {
@Override
public void copyRange(LongArray src, int srcPos, LongArray dst, int
dstPos, int length) {
- Platform.copyMemory(
- src.getBaseObject(),
- src.getBaseOffset() + srcPos * 8L,
- dst.getBaseObject(),
- dst.getBaseOffset() + dstPos * 8L,
- length * 8L
- );
+ MemoryBlock.copyMemory(src.memoryBlock(),srcPos * 8L,
--- End diff --
ditto
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
