HBASE-16616 Rpc handlers stuck on ThreadLocalMap.expungeStaleEntry (Tomu Tsuruhara)
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/8855670c Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/8855670c Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/8855670c Branch: refs/heads/hbase-12439 Commit: 8855670cd701fdf9c2ab41907f9525d122608e6d Parents: 552400e Author: tedyu <yuzhih...@gmail.com> Authored: Mon Sep 12 15:49:23 2016 -0700 Committer: tedyu <yuzhih...@gmail.com> Committed: Mon Sep 12 15:49:23 2016 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/hadoop/hbase/util/Counter.java | 4 ++++ .../src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java | 1 + 2 files changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/8855670c/hbase-common/src/main/java/org/apache/hadoop/hbase/util/Counter.java ---------------------------------------------------------------------- diff --git a/hbase-common/src/main/java/org/apache/hadoop/hbase/util/Counter.java b/hbase-common/src/main/java/org/apache/hadoop/hbase/util/Counter.java index 7b8a7e9..92c0a8f 100644 --- a/hbase-common/src/main/java/org/apache/hadoop/hbase/util/Counter.java +++ b/hbase-common/src/main/java/org/apache/hadoop/hbase/util/Counter.java @@ -181,6 +181,10 @@ public class Counter { return sum; } + public void destroy() { + indexHolderThreadLocal.remove(); + } + @Override public String toString() { Cell[] cells = containerRef.get().cells; http://git-wip-us.apache.org/repos/asf/hbase/blob/8855670c/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 0df5097..a678237 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 @@ -1957,6 +1957,7 @@ public class RpcServer implements RpcServerInterface, ConfigurationObserver { LOG.trace("Ignored exception", ignored); } } + rpcCount.destroy(); } private UserGroupInformation createUser(ConnectionHeader head) {