diff --git hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java index 31484bb..99734fd 100644 --- hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java +++ hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/CallRunner.java @@ -71,6 +71,7 @@ public class CallRunner { if (RpcServer.LOG.isDebugEnabled()) { RpcServer.LOG.debug(Thread.currentThread().getName() + ": skipped " + call); } + this.rpcServer.addCallSize(call.getSize() * -1); return; } this.status.setStatus("Setting up call");