Index: hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java =================================================================== --- hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java (revision 1567516) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java (working copy) @@ -67,6 +67,10 @@ public void run() { try { + if (!call.connection.channel.isOpen()) { + RpcServer.LOG.info(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()) {