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

Reply via email to