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

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

This commit is contained in:
Enis Soztutar 2014-12-01 20:10:20 -08:00
parent 703848ceea
commit 94d57f81dc
1 changed files with 4 additions and 2 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

@ -1719,7 +1719,8 @@ public class RpcServer implements RpcServerInterface {
responder, totalRequestSize, null); responder, totalRequestSize, null);
ByteArrayOutputStream responseBuffer = new ByteArrayOutputStream(); ByteArrayOutputStream responseBuffer = new ByteArrayOutputStream();
setupResponse(responseBuffer, callTooBig, new CallQueueTooBigException(), setupResponse(responseBuffer, callTooBig, new CallQueueTooBigException(),
"Call queue is full, is hbase.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); responder.doRespond(callTooBig);
return; return;
} }
@ -1745,7 +1746,8 @@ public class RpcServer implements RpcServerInterface {
buf, offset, buf.length); buf, offset, buf.length);
} }
} catch (Throwable t) { } 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); LOG.warn(msg, t);
// probably the hbase hadoop version does not match the running hadoop version // probably the hbase hadoop version does not match the running hadoop version