Index: src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java (revision 1228412) +++ src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java (working copy) @@ -1343,6 +1343,7 @@ errorClass, error); } call.sendResponseIfReady(); + status.markComplete("Sent response"); } catch (InterruptedException e) { if (running) { // unexpected -- log it LOG.info(getName() + " caught: " + Index: src/main/java/org/apache/hadoop/hbase/monitoring/MonitoredRPCHandlerImpl.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/monitoring/MonitoredRPCHandlerImpl.java (revision 1228412) +++ src/main/java/org/apache/hadoop/hbase/monitoring/MonitoredRPCHandlerImpl.java (working copy) @@ -217,6 +217,12 @@ this.remotePort = remotePort; } + @Override + public void markComplete(String status) { + super.markComplete(status); + this.packet = null; + } + public synchronized Map toMap() { // only include RPC info if the Handler is actively servicing an RPC call Map map = super.toMap();