This is an automated email from the ASF dual-hosted git repository.
zuston pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/uniffle.git
The following commit(s) were added to refs/heads/master by this push:
new 14a50985a [#2591] fix(client): Incorrect header length for
getLocalShuffleDataV3 (#2604)
14a50985a is described below
commit 14a50985a01244192b85ed5ff9c61625c9912319
Author: Junfan Zhang <[email protected]>
AuthorDate: Thu Sep 11 17:43:04 2025 +0800
[#2591] fix(client): Incorrect header length for getLocalShuffleDataV3
(#2604)
### What changes were proposed in this pull request?
Fix incorrect header length for getLocalShuffleDataV3
### Why are the changes needed?
This will make getLocalShuffleDataV3 invalid
### Does this PR introduce _any_ user-facing change?
No.
### How was this patch tested?
Tested in our internal jobs.
---
.../uniffle/common/netty/protocol/GetLocalShuffleDataV3Request.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git
a/common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleDataV3Request.java
b/common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleDataV3Request.java
index 993b80c51..66cd5a3c7 100644
---
a/common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleDataV3Request.java
+++
b/common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleDataV3Request.java
@@ -64,7 +64,10 @@ public class GetLocalShuffleDataV3Request extends
GetLocalShuffleDataV2Request {
@Override
public int encodedLength() {
- return super.encodedLength() + Long.BYTES * 2 * nextReadSegments.size();
+ return super.encodedLength()
+ + Integer.BYTES
+ + Long.BYTES * 2 * nextReadSegments.size()
+ + Long.BYTES;
}
@Override