You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by sy...@apache.org on 2016/09/19 23:17:27 UTC
[14/50] [abbrv] hbase git commit: HBASE-16616 Rpc handlers stuck on
ThreadLocalMap.expungeStaleEntry (Tomu Tsuruhara)
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 <yu...@gmail.com>
Authored: Mon Sep 12 15:49:23 2016 -0700
Committer: tedyu <yu...@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) {