Repository: hbase Updated Branches: refs/heads/branch-1 4581d54cf -> 2ecb4b1b3
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/2ecb4b1b Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/2ecb4b1b Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/2ecb4b1b Branch: refs/heads/branch-1 Commit: 2ecb4b1b34e8332274847497b3ffb13e57563471 Parents: 4581d54 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:28 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/2ecb4b1b/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) {
