hbase git commit: HBASE-21357 RS should abort if OOM in Reader thread

2018-11-16 Thread busbey 
Repository: hbase
Updated Branches:
  refs/heads/branch-1.2 d5fb0a585 -> b8a7edab8


HBASE-21357 RS should abort if OOM in Reader thread


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

Branch: refs/heads/branch-1.2
Commit: b8a7edab8be70ee860cd4242b397980d066c1ae7
Parents: d5fb0a5
Author: Allan Yang 
Authored: Wed Oct 24 11:10:20 2018 +0800
Committer: Sean Busbey 
Committed: Fri Nov 16 23:23:00 2018 -0600

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


http://git-wip-us.apache.org/repos/asf/hbase/blob/b8a7edab/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 4f8101b..9708b12 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
@@ -652,6 +652,17 @@ public class RpcServer implements RpcServerInterface, 
ConfigurationObserver {
 return;
   } catch (IOException ex) {
 LOG.info(getName() + ": IOException in Reader", ex);
+  } catch (OutOfMemoryError e) {
+if (getErrorHandler() != null) {
+  if (getErrorHandler().checkOOME(e)) {
+RpcServer.LOG.info(Thread.currentThread().getName()
++ ": exiting on OutOfMemoryError");
+return;
+  }
+} else {
+  // rethrow if no handler
+  throw e;
+}
   }
 }
   }

hbase git commit: HBASE-21357 RS should abort if OOM in Reader thread

2018-11-08 Thread apurtell 
Repository: hbase
Updated Branches:
  refs/heads/branch-1.3 6bb7b4cde -> f5495b7c8


HBASE-21357 RS should abort if OOM in Reader thread


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

Branch: refs/heads/branch-1.3
Commit: f5495b7c84c4af21b4955fc9ec4eb3dd5c9d5f26
Parents: 6bb7b4c
Author: Allan Yang 
Authored: Wed Oct 24 11:10:20 2018 +0800
Committer: Andrew Purtell 
Committed: Thu Nov 8 10:48:19 2018 -0800

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


http://git-wip-us.apache.org/repos/asf/hbase/blob/f5495b7c/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 8f8c22f..152a71c 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
@@ -734,6 +734,17 @@ public class RpcServer implements RpcServerInterface, 
ConfigurationObserver {
 return;
   } catch (IOException ex) {
 LOG.info(getName() + ": IOException in Reader", ex);
+  } catch (OutOfMemoryError e) {
+if (getErrorHandler() != null) {
+  if (getErrorHandler().checkOOME(e)) {
+RpcServer.LOG.info(Thread.currentThread().getName()
++ ": exiting on OutOfMemoryError");
+return;
+  }
+} else {
+  // rethrow if no handler
+  throw e;
+}
   }
 }
   }

hbase git commit: HBASE-21357 RS should abort if OOM in Reader thread

2018-11-08 Thread apurtell 
Repository: hbase
Updated Branches:
  refs/heads/branch-1.4 58dfaab4f -> 745cc7a03


HBASE-21357 RS should abort if OOM in Reader thread


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

Branch: refs/heads/branch-1.4
Commit: 745cc7a0328ba7fe5bbf63de44af45825b036208
Parents: 58dfaab
Author: Allan Yang 
Authored: Wed Oct 24 11:10:20 2018 +0800
Committer: Andrew Purtell 
Committed: Thu Nov 8 10:48:01 2018 -0800

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


http://git-wip-us.apache.org/repos/asf/hbase/blob/745cc7a0/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 3f11233..a32040c 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
@@ -732,6 +732,17 @@ public class RpcServer implements RpcServerInterface, 
ConfigurationObserver {
 LOG.error(getName() + ": CancelledKeyException in Reader", e);
   } catch (IOException ex) {
 LOG.info(getName() + ": IOException in Reader", ex);
+  } catch (OutOfMemoryError e) {
+if (getErrorHandler() != null) {
+  if (getErrorHandler().checkOOME(e)) {
+RpcServer.LOG.info(Thread.currentThread().getName()
++ ": exiting on OutOfMemoryError");
+return;
+  }
+} else {
+  // rethrow if no handler
+  throw e;
+}
   }
 }
   }

hbase git commit: HBASE-21357 RS should abort if OOM in Reader thread

2018-10-23 Thread allan163 
Repository: hbase
Updated Branches:
  refs/heads/branch-1 f73d6193e -> 5f5f4e82b


HBASE-21357 RS should abort if OOM in Reader thread


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

Branch: refs/heads/branch-1
Commit: 5f5f4e82b126b27f833f643abeded67dae3af05d
Parents: f73d619
Author: Allan Yang 
Authored: Wed Oct 24 11:10:20 2018 +0800
Committer: Allan Yang 
Committed: Wed Oct 24 11:10:20 2018 +0800

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


http://git-wip-us.apache.org/repos/asf/hbase/blob/5f5f4e82/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 3f11233..a32040c 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
@@ -732,6 +732,17 @@ public class RpcServer implements RpcServerInterface, 
ConfigurationObserver {
 LOG.error(getName() + ": CancelledKeyException in Reader", e);
   } catch (IOException ex) {
 LOG.info(getName() + ": IOException in Reader", ex);
+  } catch (OutOfMemoryError e) {
+if (getErrorHandler() != null) {
+  if (getErrorHandler().checkOOME(e)) {
+RpcServer.LOG.info(Thread.currentThread().getName()
++ ": exiting on OutOfMemoryError");
+return;
+  }
+} else {
+  // rethrow if no handler
+  throw e;
+}
   }
 }
   }