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 03c0e14f3fb..31484bb5fb4 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 @@ -67,6 +67,12 @@ public class CallRunner { public void run() { try { + if (!call.connection.channel.isOpen()) { + if (RpcServer.LOG.isDebugEnabled()) { + RpcServer.LOG.debug(Thread.currentThread().getName() + ": skipped " + call); + } + return; + } this.status.setStatus("Setting up call"); this.status.setConnection(call.connection.getHostAddress(), call.connection.getRemotePort()); if (RpcServer.LOG.isDebugEnabled()) { @@ -147,4 +153,4 @@ public class CallRunner { RpcServer.MONITORED_RPC.set(status); return status; } -} \ No newline at end of file +}