Github user yucai commented on a diff in the pull request:
https://github.com/apache/spark/pull/19788#discussion_r165409015
--- Diff:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ExternalShuffleBlockResolver.java
---
@@ -165,13 +165,23 @@ public ManagedBuffer getBlockData(
String execId,
int shuffleId,
int mapId,
- int reduceId) {
+ int reduceId,
+ int length) {
--- End diff --
Ok, will use numBlocks.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
