Repository: hbase Updated Branches: refs/heads/master d8a262996 -> 2c3340c00
HBASE-11718 Remove some logs in RpcClient.java Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/2c3340c0 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/2c3340c0 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/2c3340c0 Branch: refs/heads/master Commit: 2c3340c00ad5934d450f5677f2ee7e21a2855793 Parents: d8a2629 Author: Nicolas Liochon <[email protected]> Authored: Tue Aug 12 09:52:24 2014 +0200 Committer: Nicolas Liochon <[email protected]> Committed: Tue Aug 12 09:52:24 2014 +0200 ---------------------------------------------------------------------- .../java/org/apache/hadoop/hbase/ipc/RpcClient.java | 12 ------------ 1 file changed, 12 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/2c3340c0/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/RpcClient.java ---------------------------------------------------------------------- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/RpcClient.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/RpcClient.java index 5959da3..0262462 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/RpcClient.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/RpcClient.java @@ -1129,10 +1129,6 @@ public class RpcClient { // Now that we notified, we can rethrow the exception if any. Otherwise we're good. if (writeException != null) throw writeException; - - if (LOG.isDebugEnabled()) { - LOG.debug(getName() + ": wrote request header " + TextFormat.shortDebugString(header)); - } } /* Receive a response. @@ -1150,10 +1146,6 @@ public class RpcClient { // Read the header ResponseHeader responseHeader = ResponseHeader.parseDelimitedFrom(in); int id = responseHeader.getCallId(); - if (LOG.isDebugEnabled()) { - LOG.debug(getName() + ": got response header " + - TextFormat.shortDebugString(responseHeader) + ", totalSize: " + totalSize + " bytes"); - } call = calls.remove(id); // call.done have to be set before leaving this method expectedCall = (call != null && !call.done); if (!expectedCall) { @@ -1164,10 +1156,6 @@ public class RpcClient { // this connection. int readSoFar = IPCUtil.getTotalSizeWhenWrittenDelimited(responseHeader); int whatIsLeftToRead = totalSize - readSoFar; - if (LOG.isDebugEnabled()) { - LOG.debug("Unknown callId: " + id + ", skipping over this response of " + - whatIsLeftToRead + " bytes"); - } IOUtils.skipFully(in, whatIsLeftToRead); } if (responseHeader.hasException()) {
