Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-15551 Make call queue too big exception use servername

This commit is contained in:
Mikhail Antonov 2016-04-29 10:25:14 -07:00
parent cd148b7cee
commit 730b077666
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java
View File

@ -1877,9 +1877,8 @@ public class RpcServer implements RpcServerInterface, ConfigurationObserver {
responder, totalRequestSize, null, null); responder, totalRequestSize, null, null);
ByteArrayOutputStream responseBuffer = new ByteArrayOutputStream(); ByteArrayOutputStream responseBuffer = new ByteArrayOutputStream();
metrics.exception(CALL_QUEUE_TOO_BIG_EXCEPTION); metrics.exception(CALL_QUEUE_TOO_BIG_EXCEPTION);
InetSocketAddress address = getListenerAddress();
setupResponse(responseBuffer, callTooBig, CALL_QUEUE_TOO_BIG_EXCEPTION, 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?"); ", is hbase.ipc.server.max.callqueue.size too small?");
responder.doRespond(callTooBig); responder.doRespond(callTooBig);
return; return;
@ -1943,9 +1942,8 @@ public class RpcServer implements RpcServerInterface, ConfigurationObserver {
ByteArrayOutputStream responseBuffer = new ByteArrayOutputStream(); ByteArrayOutputStream responseBuffer = new ByteArrayOutputStream();
metrics.exception(CALL_QUEUE_TOO_BIG_EXCEPTION); metrics.exception(CALL_QUEUE_TOO_BIG_EXCEPTION);
InetSocketAddress address = getListenerAddress();
setupResponse(responseBuffer, call, CALL_QUEUE_TOO_BIG_EXCEPTION, 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 ?"); ", too many items queued ?");
responder.doRespond(call); responder.doRespond(call);
} }