hbase git commit: HBASE-21357 RS should abort if OOM in Reader thread
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
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
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
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; +} } } }