hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From anto...@apache.org
Subject hbase git commit: HBASE-15551 Make call queue too big exception use servername
Date Fri, 29 Apr 2016 17:27:01 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1 44fdfb3ba -> e6bcf95da


HBASE-15551 Make call queue too big exception use servername


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

Branch: refs/heads/branch-1
Commit: e6bcf95da501d726aaa208ffaa9dfbfd55fe985b
Parents: 44fdfb3
Author: Mikhail Antonov <antonov@apache.org>
Authored: Fri Apr 29 10:25:14 2016 -0700
Committer: Mikhail Antonov <antonov@apache.org>
Committed: Fri Apr 29 10:26:18 2016 -0700

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


http://git-wip-us.apache.org/repos/asf/hbase/blob/e6bcf95d/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 286d1dd..a909352 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
@@ -1863,9 +1863,8 @@ public class RpcServer implements RpcServerInterface, ConfigurationObserver
{
             responder, totalRequestSize, null, null);
         ByteArrayOutputStream responseBuffer = new ByteArrayOutputStream();
         metrics.exception(CALL_QUEUE_TOO_BIG_EXCEPTION);
-        InetSocketAddress address = getListenerAddress();
         setupResponse(responseBuffer, callTooBig, CALL_QUEUE_TOO_BIG_EXCEPTION,
-            "Call queue is full on " + (address != null ? address : "(channel closed)") +
+            "Call queue is full on " + server.getServerName() +
                 ", is hbase.ipc.server.max.callqueue.size too small?");
         responder.doRespond(callTooBig);
         return;
@@ -1929,9 +1928,8 @@ public class RpcServer implements RpcServerInterface, ConfigurationObserver
{
 
         ByteArrayOutputStream responseBuffer = new ByteArrayOutputStream();
         metrics.exception(CALL_QUEUE_TOO_BIG_EXCEPTION);
-        InetSocketAddress address = getListenerAddress();
         setupResponse(responseBuffer, call, CALL_QUEUE_TOO_BIG_EXCEPTION,
-            "Call queue is full on " + (address != null ? address : "(channel closed)") +
+            "Call queue is full on " + server.getServerName() +
                 ", too many items queued ?");
         responder.doRespond(call);
       }


Mime
View raw message