We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c9c2e4e commit 16b2d70Copy full SHA for 16b2d70
network/common/src/main/java/org/apache/spark/network/protocol/MessageWithHeader.java
@@ -37,7 +37,7 @@ class MessageWithHeader extends AbstractReferenceCounted implements FileRegion {
37
private final int headerLength;
38
private final Object body;
39
private final long bodyLength;
40
- private int totalBytesTransferred;
+ private long totalBytesTransferred;
41
42
MessageWithHeader(ByteBuf header, Object body, long bodyLength) {
43
Preconditions.checkArgument(body instanceof ByteBuf || body instanceof FileRegion,
0 commit comments