hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e...@apache.org
Subject hbase git commit: HBASE-12537 HBase should log the remote host on replication error (Stack)
Date Tue, 02 Dec 2014 04:13:27 GMT
Repository: hbase
Updated Branches:
  refs/heads/0.98 0d7ddab0d -> 72b4adbcf


HBASE-12537 HBase should log the remote host on replication error (Stack)

Conflicts:
	hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/72b4adbc
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/72b4adbc
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/72b4adbc

Branch: refs/heads/0.98
Commit: 72b4adbcf33b38e197ac0e0598917508f8ebb231
Parents: 0d7ddab
Author: Enis Soztutar <enis@apache.org>
Authored: Mon Dec 1 20:10:20 2014 -0800
Committer: Enis Soztutar <enis@apache.org>
Committed: Mon Dec 1 20:13:16 2014 -0800

----------------------------------------------------------------------
 .../src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java   | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/72b4adbc/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java
index d2b0ab1..f031b0b 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java
@@ -1690,7 +1690,8 @@ public class RpcServer implements RpcServerInterface {
             responder, totalRequestSize, null);
         ByteArrayOutputStream responseBuffer = new ByteArrayOutputStream();
         setupResponse(responseBuffer, callTooBig, new CallQueueTooBigException(),
-          "Call queue is full, is ipc.server.max.callqueue.size too small?");
+          "Call queue is full on " + getListenerAddress() +
+          ", is hbase.ipc.server.max.callqueue.size too small?");
         responder.doRespond(callTooBig);
         return;
       }
@@ -1716,7 +1717,8 @@ public class RpcServer implements RpcServerInterface {
             buf, offset, buf.length);
         }
       } catch (Throwable t) {
-        String msg = "Unable to read call parameter from client " + getHostAddress();
+        String msg = getListenerAddress() + " is unable to read call parameter from client
" +
+            getHostAddress();
         LOG.warn(msg, t);
 
         // probably the hbase hadoop version does not match the running hadoop version


Mime
View raw message