Repository: hbase Updated Branches: refs/heads/master 4d7c65ae8 -> 4bfd35aab
HBASE-12825 CallRunner exception messages should include destination host:port Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/4bfd35aa Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/4bfd35aa Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/4bfd35aa Branch: refs/heads/master Commit: 4bfd35aabc83b007871fe9a8537cd5ac9cd84500 Parents: 4d7c65a Author: Nick Dimiduk <[email protected]> Authored: Thu Jan 8 18:38:24 2015 -0800 Committer: Nick Dimiduk <[email protected]> Committed: Thu Jan 8 18:40:01 2015 -0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/4bfd35aa/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java index 56bd96b..d4364ab 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java @@ -48,8 +48,6 @@ public class CallRunner { * On construction, adds the size of this call to the running count of outstanding call sizes. * Presumption is that we are put on a queue while we wait on an executor to run us. During this * time we occupy heap. - * @param call The call to run. - * @param rpcServer */ // The constructor is shutdown so only RpcServer in this class can make one of these. CallRunner(final RpcServerInterface rpcServer, final Call call, UserProvider userProvider) { @@ -97,7 +95,8 @@ public class CallRunner { TraceScope traceScope = null; try { if (!this.rpcServer.isStarted()) { - throw new ServerNotRunningYetException("Server is not running yet"); + throw new ServerNotRunningYetException("Server " + rpcServer.getListenerAddress() + + " is not running yet"); } if (call.tinfo != null) { traceScope = Trace.startSpan(call.toTraceString(), call.tinfo); @@ -145,7 +144,7 @@ public class CallRunner { } } catch (ClosedChannelException cce) { RpcServer.LOG.warn(Thread.currentThread().getName() + ": caught a ClosedChannelException, " + - "this means that the server was processing a " + + "this means that the server " + rpcServer.getListenerAddress() + " was processing a " + "request but the client went away. The error message was: " + cce.getMessage()); } catch (Exception e) {
