Github user mridulm commented on a diff in the pull request:
https://github.com/apache/spark/pull/19788#discussion_r158124746
--- Diff:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/ShuffleIndexInformation.java
---
@@ -59,9 +59,9 @@ public int getSize() {
/**
* Get index offset for a particular reducer.
*/
- public ShuffleIndexRecord getIndex(int reduceId) {
+ public ShuffleIndexRecord getIndex(int reduceId, int length) {
--- End diff --
perhaps `require` that length (number of Blocks) is >= 1
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
