[34/50] hbase git commit: HBASE-16165 Decrease RpcServer.callQueueSize before writeResponse causes OOM (Guanghao Zhang)

2016-11-01 Thread larsh 
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/efd1ba15
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/efd1ba15
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/efd1ba15

Branch: refs/heads/0.98
Commit: efd1ba157a13f18113ca9cb9aca5f76e6df1209b
Parents: 73fa9d6
Author: zhangduo 
Authored: Sun Sep 18 10:06:50 2016 +0800
Committer: zhangduo 
Committed: Sun Sep 18 10:07:19 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/efd1ba15/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 50e16c0..f946753 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
@@ -580,6 +580,8 @@ public class RpcServer implements RpcServerInterface {
  * called by the RPC code in the context of the Handler thread.
  */
 public synchronized void sendResponseIfReady() throws IOException {
+  // set param null to reduce memory pressure
+  this.param = null;
   if (!this.delayResponse) {
 this.responder.doRespond(this);
   }

[15/50] [abbrv] hbase git commit: HBASE-16165 Decrease RpcServer.callQueueSize before writeResponse causes OOM (Guanghao Zhang)

2016-09-22 Thread busbey 
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/hbase-14439
Commit: 4faa8ea934ba5d9cc8ea4eb0d1e64a38a5e6dc7d
Parents: da3abbc
Author: zhangduo 
Authored: Sun Sep 18 10:05:27 2016 +0800
Committer: zhangduo 
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);
 }

[46/50] [abbrv] hbase git commit: HBASE-16165 Decrease RpcServer.callQueueSize before writeResponse causes OOM (Guanghao Zhang)

2016-09-19 Thread syuanjiang 
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/hbase-12439
Commit: 4faa8ea934ba5d9cc8ea4eb0d1e64a38a5e6dc7d
Parents: da3abbc
Author: zhangduo 
Authored: Sun Sep 18 10:05:27 2016 +0800
Committer: zhangduo 
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);
 }

hbase git commit: HBASE-16165 Decrease RpcServer.callQueueSize before writeResponse causes OOM (Guanghao Zhang)

2016-09-17 Thread zhangduo 
Repository: hbase
Updated Branches:
  refs/heads/branch-1.1 ff914375f -> 31a2f04e9


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/31a2f04e
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/31a2f04e
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/31a2f04e

Branch: refs/heads/branch-1.1
Commit: 31a2f04e996cf4022530e89f090ac770f8e1c9dd
Parents: ff91437
Author: zhangduo 
Authored: Sun Sep 18 10:06:50 2016 +0800
Committer: zhangduo 
Committed: Sun Sep 18 10:06:50 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/31a2f04e/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 6ba125e..c830b73 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
@@ -533,6 +533,8 @@ public class RpcServer implements RpcServerInterface {
  * called by the RPC code in the context of the Handler thread.
  */
 public synchronized void sendResponseIfReady() throws IOException {
+  // set param null to reduce memory pressure
+  this.param = null;
   if (!this.delayResponse) {
 this.responder.doRespond(this);
   }

hbase git commit: HBASE-16165 Decrease RpcServer.callQueueSize before writeResponse causes OOM (Guanghao Zhang)

2016-09-17 Thread zhangduo 
Repository: hbase
Updated Branches:
  refs/heads/0.98 73fa9d6ec -> efd1ba157


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/efd1ba15
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/efd1ba15
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/efd1ba15

Branch: refs/heads/0.98
Commit: efd1ba157a13f18113ca9cb9aca5f76e6df1209b
Parents: 73fa9d6
Author: zhangduo 
Authored: Sun Sep 18 10:06:50 2016 +0800
Committer: zhangduo 
Committed: Sun Sep 18 10:07:19 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/efd1ba15/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 50e16c0..f946753 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
@@ -580,6 +580,8 @@ public class RpcServer implements RpcServerInterface {
  * called by the RPC code in the context of the Handler thread.
  */
 public synchronized void sendResponseIfReady() throws IOException {
+  // set param null to reduce memory pressure
+  this.param = null;
   if (!this.delayResponse) {
 this.responder.doRespond(this);
   }

hbase git commit: HBASE-16165 Decrease RpcServer.callQueueSize before writeResponse causes OOM (Guanghao Zhang)

2016-09-17 Thread zhangduo 
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 
Authored: Sun Sep 18 10:05:27 2016 +0800
Committer: zhangduo 
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);
 }

hbase git commit: HBASE-16165 Decrease RpcServer.callQueueSize before writeResponse causes OOM (Guanghao Zhang)

2016-09-17 Thread zhangduo 
Repository: hbase
Updated Branches:
  refs/heads/branch-1.3 55d3dc415 -> e9a5c60d1


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/e9a5c60d
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/e9a5c60d
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/e9a5c60d

Branch: refs/heads/branch-1.3
Commit: e9a5c60d139dd12cd5d395ef80344591242842c5
Parents: 55d3dc4
Author: zhangduo 
Authored: Sun Sep 18 10:05:27 2016 +0800
Committer: zhangduo 
Committed: Sun Sep 18 10:05:54 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/e9a5c60d/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 1576c2a..72d2531 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
@@ -574,6 +574,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);
 }

hbase git commit: HBASE-16165 Decrease RpcServer.callQueueSize before writeResponse causes OOM (Guanghao Zhang)

2016-09-17 Thread zhangduo 
Repository: hbase
Updated Branches:
  refs/heads/branch-1 591cc4cfb -> 91d03697d


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/91d03697
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/91d03697
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/91d03697

Branch: refs/heads/branch-1
Commit: 91d03697d93bce227f27af863a6427e661ac511c
Parents: 591cc4c
Author: zhangduo 
Authored: Sun Sep 18 10:05:27 2016 +0800
Committer: zhangduo 
Committed: Sun Sep 18 10:05:48 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/91d03697/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 854573a..db615a8 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
@@ -574,6 +574,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);
 }

hbase git commit: HBASE-16165 Decrease RpcServer.callQueueSize before writeResponse causes OOM (Guanghao Zhang)

2016-09-17 Thread zhangduo 
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 
Authored: Sun Sep 18 10:05:27 2016 +0800
Committer: zhangduo 
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);
 }