diff --git a/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientGrpc.java b/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientGrpc.java index eea2bf37df7f..240214611698 100644 --- a/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientGrpc.java +++ b/hadoop-hdds/client/src/main/java/org/apache/hadoop/hdds/scm/XceiverClientGrpc.java @@ -280,7 +280,13 @@ public ContainerCommandResponseProto sendCommand( // Re-interrupt the thread while catching InterruptedException Thread.currentThread().interrupt(); } catch (ExecutionException e) { - LOG.error("Failed to execute command {}", processForDebug(request), e); + String message = "Failed to execute command {}."; + if (LOG.isDebugEnabled()) { + LOG.debug(message, processForDebug(request), e); + } else { + LOG.error(message + " Exception Class: {}, Exception Message: {}", + request.getCmdType(), e.getClass().getName(), e.getMessage()); + } } return responseProtoHashMap; } diff --git a/hadoop-hdds/client/src/main/java/org/apache/hadoop/ozone/client/io/ECBlockInputStreamProxy.java b/hadoop-hdds/client/src/main/java/org/apache/hadoop/ozone/client/io/ECBlockInputStreamProxy.java index 49ee7c753825..5427e300cec3 100644 --- a/hadoop-hdds/client/src/main/java/org/apache/hadoop/ozone/client/io/ECBlockInputStreamProxy.java +++ b/hadoop-hdds/client/src/main/java/org/apache/hadoop/ozone/client/io/ECBlockInputStreamProxy.java @@ -165,8 +165,15 @@ public synchronized int read(ByteBuffer buf) throws IOException { throw e; } if (e instanceof BadDataLocationException) { - LOG.warn("Failing over to reconstruction read due to an error in " + - "ECBlockReader", e); + String message = "Failing over to reconstruction read due" + + " to an error in ECBlockReader."; + if (LOG.isDebugEnabled()) { + LOG.debug(message, e); + } else { + LOG.warn("{} Exception Class: {} , Exception Message: {}", + message, e.getClass().getName(), e.getMessage()); + } + failoverToReconstructionRead( ((BadDataLocationException) e).getFailedLocation(), lastPosition); buf.reset();