(fluss) branch main updated: [log] Output the leader server id and related table ids on fetching log failure (#2792)

[aborisov]

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

fresh-borzoni pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new e0f6cff6f [log] Output the leader server id and related table ids on 
fetching log failure (#2792)
e0f6cff6f is described below

commit e0f6cff6fc8879be9c61c4558351c865f641f88d
Author: Junfan Zhang <zus...@apache.org>
AuthorDate: Fri May 29 00:02:15 2026 +0800

    [log] Output the leader server id and related table ids on fetching log 
failure (#2792)
    
    Co-authored-by: Junfan Zhang <zhangjun...@qiyi.com>
---
 .../fluss/server/replica/fetcher/ReplicaFetcherThread.java       | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/fluss-server/src/main/java/org/apache/fluss/server/replica/fetcher/ReplicaFetcherThread.java
 
b/fluss-server/src/main/java/org/apache/fluss/server/replica/fetcher/ReplicaFetcherThread.java
index f7099140f..cc430a19f 100644
--- 
a/fluss-server/src/main/java/org/apache/fluss/server/replica/fetcher/ReplicaFetcherThread.java
+++ 
b/fluss-server/src/main/java/org/apache/fluss/server/replica/fetcher/ReplicaFetcherThread.java
@@ -66,6 +66,7 @@ import java.util.concurrent.TimeUnit;
 import java.util.concurrent.locks.Condition;
 import java.util.concurrent.locks.Lock;
 import java.util.concurrent.locks.ReentrantLock;
+import java.util.stream.Collectors;
 
 import static org.apache.fluss.utils.Preconditions.checkNotNull;
 import static org.apache.fluss.utils.concurrent.LockUtils.inLock;
@@ -241,7 +242,13 @@ final class ReplicaFetcherThread extends 
ShutdownableThread {
             responseData = fetchFuture.get(timeoutSeconds, TimeUnit.SECONDS);
         } catch (Throwable t) {
             if (isRunning()) {
-                LOG.warn("Error in response for fetch log request {}", 
fetchLogRequest, t);
+                LOG.warn(
+                        "Error in response from leader server {} for fetch log 
request from table ids: {}",
+                        leader.leaderServerId(),
+                        fetchLogRequest.getTablesReqsList().stream()
+                                .map(x -> x.getTableId())
+                                .collect(Collectors.toSet()),
+                        t);
                 inLock(
                         bucketStatusMapLock,
                         () -> 
bucketsWithError.addAll(fairBucketStatusMap.bucketSet()));