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.",