(incubator-uniffle) branch master updated: [#1811] improvement(netty): Print received Netty ByteBuf readable bytes in clients (#1812)

[rickyma]

This is an automated email from the ASF dual-hosted git repository.

rickyma pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-uniffle.git


The following commit(s) were added to refs/heads/master by this push:
     new e37a09ce5 [#1811] improvement(netty): Print received Netty ByteBuf 
readable bytes in clients (#1812)
e37a09ce5 is described below

commit e37a09ce5bb9d54463fdb45c91435a22eb75ac13
Author: RickyMa <rick...@tencent.com>
AuthorDate: Thu Jun 20 15:24:12 2024 +0800

    [#1811] improvement(netty): Print received Netty ByteBuf readable bytes in 
clients (#1812)
    
    ### What changes were proposed in this pull request?
    
    Print received Netty ByteBuf's readable bytes in clients.
    
    ### Why are the changes needed?
    
    For: https://github.com/apache/incubator-uniffle/issues/1811.
    
    ### Does this PR introduce _any_ user-facing change?
    
    No.
    
    ### How was this patch tested?
    
    Existing UTs.
---
 .../uniffle/client/impl/grpc/ShuffleServerGrpcNettyClient.java   | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git 
a/internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerGrpcNettyClient.java
 
b/internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerGrpcNettyClient.java
index 806fd3c21..e0bd31c0c 100644
--- 
a/internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerGrpcNettyClient.java
+++ 
b/internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerGrpcNettyClient.java
@@ -283,7 +283,8 @@ public class ShuffleServerGrpcNettyClient extends 
ShuffleServerGrpcClient {
     switch (rpcResponse.getStatusCode()) {
       case SUCCESS:
         LOG.info(
-            "GetInMemoryShuffleData from {}:{} for {} cost {} ms",
+            "GetInMemoryShuffleData size:{}(bytes) from {}:{} for {} 
cost:{}(ms)",
+            getMemoryShuffleDataResponse.body().size(),
             host,
             nettyPort,
             requestInfo,
@@ -341,7 +342,8 @@ public class ShuffleServerGrpcNettyClient extends 
ShuffleServerGrpcClient {
     switch (rpcResponse.getStatusCode()) {
       case SUCCESS:
         LOG.info(
-            "GetShuffleIndex from {}:{} for {} cost {} ms",
+            "GetShuffleIndex size:{}(bytes) from {}:{} for {} cost:{}(ms)",
+            getLocalShuffleIndexResponse.body().size(),
             host,
             nettyPort,
             requestInfo,
@@ -403,7 +405,8 @@ public class ShuffleServerGrpcNettyClient extends 
ShuffleServerGrpcClient {
     switch (rpcResponse.getStatusCode()) {
       case SUCCESS:
         LOG.info(
-            "GetShuffleData from {}:{} for {} cost {} ms",
+            "GetShuffleData size:{}(bytes) from {}:{} for {} cost:{}(ms)",
+            getLocalShuffleDataResponse.body().size(),
             host,
             nettyPort,
             requestInfo,