add local store to logs (#2947)

Co-authored-by: Navneet Sachan <nsachan@nsachan-mn1.linkedin.biz>
linkedin · Nov 21, 2024 · d33bb81 · d33bb81
1 parent 316d148
commit d33bb81
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/ambry-replication/src/main/java/com/github/ambry/replication/ReplicaThread.java b/ambry-replication/src/main/java/com/github/ambry/replication/ReplicaThread.java
@@ -653,7 +653,11 @@ public void replicateCyclic() {
       remoteReplicaGroups.stream()
           .filter(g -> g.isDone() && g.getException() != null)
           .forEach(g -> logger.error("Remote node: {} Thread name: {} RemoteReplicaGroup {} has exception {}",
-              g.getRemoteDataNode(), threadName, g.getRemoteReplicaInfos(), g.getException()));
+              g.getRemoteDataNode(), threadName, g.getRemoteReplicaInfos()
+                  .stream()
+                  .map(remoteReplicaInfo -> remoteReplicaInfo.toString() + ": localstore "
+                      + remoteReplicaInfo.getLocalStore().toString())
+                  .collect(Collectors.toList()), g.getException()));
     } catch (Throwable e) {
       logger.error("Thread name: {} found some error while replicating from remote hosts", threadName, e);
     } finally {