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:25:53 GMT
Repository: hbase
Updated Branches:
  refs/heads/master cd148b7ce -> 730b07766


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/730b0776
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/730b0776
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/730b0776

Branch: refs/heads/master
Commit: 730b077666ba3dc91f894ea3899fe854e6168777
Parents: cd148b7
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:25:29 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/730b0776/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 f0aed2e..b9a9b26 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
@@ -1877,9 +1877,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;
@@ -1943,9 +1942,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