Repository: hbase Updated Branches: refs/heads/master da3abbcb3 -> 4faa8ea93
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/4faa8ea9 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/4faa8ea9 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/4faa8ea9 Branch: refs/heads/master Commit: 4faa8ea934ba5d9cc8ea4eb0d1e64a38a5e6dc7d Parents: da3abbc Author: zhangduo <zhang...@apache.org> Authored: Sun Sep 18 10:05:27 2016 +0800 Committer: zhangduo <zhang...@apache.org> Committed: Sun Sep 18 10:05:27 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/4faa8ea9/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 a678237..37b60c9 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 @@ -599,6 +599,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); }
