diff --git a/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/PushBlockStream.java b/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/PushBlockStream.java index b35ac33a6020b..d5e1cf2464d9e 100644 --- a/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/PushBlockStream.java +++ b/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/PushBlockStream.java @@ -96,7 +96,7 @@ public boolean equals(Object other) { @Override public int encodedLength() { - return Encoders.Strings.encodedLength(appId) + 20; + return Encoders.Strings.encodedLength(appId) + 4 + 4 + 4 + 4 + 4; } @Override