Repository: hbase
Updated Branches:
  refs/heads/branch-1.2 b7888df61 -> 2f0a00670


HBASE-16165 Decrease RpcServer.callQueueSize before writeResponse causes OOM 
(Guanghao Zhang)


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/2f0a0067
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/2f0a0067
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/2f0a0067

Branch: refs/heads/branch-1.2
Commit: 2f0a00670af6d697b91f6cb4e853757eada22063
Parents: b7888df
Author: zhangduo <zhang...@apache.org>
Authored: Sun Sep 18 10:05:27 2016 +0800
Committer: zhangduo <zhang...@apache.org>
Committed: Sun Sep 18 10:06:04 2016 +0800

----------------------------------------------------------------------
 .../src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java       | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/2f0a0067/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java
----------------------------------------------------------------------
diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java
index ddecc64..0a27eca 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java
@@ -514,6 +514,8 @@ public class RpcServer implements RpcServerInterface, 
ConfigurationObserver {
     }
 
     public synchronized void sendResponseIfReady() throws IOException {
+      // set param null to reduce memory pressure
+      this.param = null;
       this.responder.doRespond(this);
     }
 

Reply via email to