Repository: hadoop Updated Branches: refs/heads/trunk ff2484906 -> 95d526a27
HDDS-869. Fix log message in XceiverClientRatis#sendCommandAsync. Contributed by Lokesh Jain. Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/95d526a2 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/95d526a2 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/95d526a2 Branch: refs/heads/trunk Commit: 95d526a270033462718df6e11a584b727e5c532b Parents: ff24849 Author: Shashikant Banerjee <[email protected]> Authored: Thu Nov 22 18:39:14 2018 +0530 Committer: Shashikant Banerjee <[email protected]> Committed: Thu Nov 22 18:39:14 2018 +0530 ---------------------------------------------------------------------- .../java/org/apache/hadoop/hdds/scm/XceiverClientRatis.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/95d526a2/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientRatis.java ---------------------------------------------------------------------- diff --git a/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientRatis.java b/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientRatis.java index 8a07526..28d3e7a 100644 --- a/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientRatis.java +++ b/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientRatis.java @@ -196,9 +196,11 @@ public final class XceiverClientRatis extends XceiverClientSpi { Collection<XceiverClientAsyncReply.CommitInfo> commitInfos = new ArrayList<>(); CompletableFuture<ContainerCommandResponseProto> containerCommandResponse = - raftClientReply.whenComplete((reply, e) -> LOG - .info("received reply {} for request: {} exception: {}", request, - reply, e)) + raftClientReply.whenComplete((reply, e) -> LOG.debug( + "received reply {} for request: cmdType={} containerID={}" + + " pipelineID={} traceID={} exception: {}", reply, + request.getCmdType(), request.getContainerID(), + request.getPipelineID(), request.getTraceID(), e)) .thenApply(reply -> { try { // we need to handle RaftRetryFailure Exception --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
