Victsm commented on a change in pull request #32007:
URL: https://github.com/apache/spark/pull/32007#discussion_r638417136
##########
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/PushBlockStream.java
##########
@@ -34,15 +32,17 @@
*/
public class PushBlockStream extends BlockTransferMessage {
public final String appId;
+ public final int attemptId;
public final int shuffleId;
public final int mapIndex;
public final int reduceId;
// Similar to the chunkIndex in StreamChunkId, indicating the index of a
block in a batch of
// blocks to be pushed.
public final int index;
- public PushBlockStream(String appId, int shuffleId, int mapIndex, int
reduceId, int index) {
+ public PushBlockStream(String appId, int attemptId, int shuffleId, int
mapIndex, int reduceId, int index) {
Review comment:
Nit: line too long, break into 2 lines.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
