Skip to content
Prev Previous commit
Next Next commit
add comment
  • Loading branch information
yuhaiyang authored and yuhaiyang committed Feb 26, 2021
commit 006a5ec12a93ed641c3ef91d3d7adc6e6deb7553
Original file line number Diff line number Diff line change
Expand Up @@ -117,6 +117,8 @@ private FetchShuffleBlocks createFetchShuffleBlocksMsg(
boolean batchFetchEnabled = firstBlock.length == 5;

HashMap<Long, ArrayList<Integer>> mapIdToReduceIds = new HashMap<>();
// The mapIds and reducesId must be same order with blockIds because the shuffle data's
// return order will match the `blockIds` order to ensure blockId and data match.
ArrayList<Long> orderedMapId = new ArrayList<>();
for (String blockId : blockIds) {
String[] blockIdParts = splitBlockId(blockId);
Expand Down