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 8fa51bb30 [MINOR] improvement(client): Shorten log for multi replica 
client reader (#2561)
8fa51bb30 is described below

commit 8fa51bb303e40635fcbd454687da714cb61f798a
Author: Junfan Zhang <[email protected]>
AuthorDate: Tue Jul 29 10:26:07 2025 +0800

    [MINOR] improvement(client): Shorten log for multi replica client reader 
(#2561)
    
    ### What changes were proposed in this pull request?
    
    When multi replica or partition split is enabled,  the log with blockId 
unexception message will always show when reading from one shuffle-server, that 
will make someone confuse.
    
    ### Why are the changes needed?
    
    Shorten log for multi replica client reader
    
    ### Does this PR introduce _any_ user-facing change?
    
    No.
    
    ### How was this patch tested?
    
    Neen't
---
 .../uniffle/storage/handler/impl/MultiReplicaClientReadHandler.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/storage/src/main/java/org/apache/uniffle/storage/handler/impl/MultiReplicaClientReadHandler.java
 
b/storage/src/main/java/org/apache/uniffle/storage/handler/impl/MultiReplicaClientReadHandler.java
index 025ea8c82..7b2774f6e 100644
--- 
a/storage/src/main/java/org/apache/uniffle/storage/handler/impl/MultiReplicaClientReadHandler.java
+++ 
b/storage/src/main/java/org/apache/uniffle/storage/handler/impl/MultiReplicaClientReadHandler.java
@@ -80,12 +80,12 @@ public class MultiReplicaClientReadHandler extends 
AbstractClientReadHandler {
           // If this is not the last server, then read next.
           if (readHandlerIndex < handlers.size() - 1) {
             LOG.info(
-                "Finished read from {}/{} [{}], haven't finished read all the 
blocks. Will read from next server {}",
+                "Finished read from {}/{} [{}], haven't finished read all the 
blocks. Will read from next server {}. message: {}",
                 readHandlerIndex + 1,
                 handlers.size(),
                 shuffleServerInfos.get(readHandlerIndex).getId(),
                 shuffleServerInfos.get(readHandlerIndex + 1).getId(),
-                e);
+                e.getMessage());
           } else {
             LOG.warn(
                 "Finished read from {}/{} [{}], but haven't finished read all 
the blocks.",

Reply via email to