hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From te...@apache.org
Subject hbase git commit: HBASE-16616 Rpc handlers stuck on ThreadLocalMap.expungeStaleEntry (Tomu Tsuruhara)
Date Mon, 12 Sep 2016 22:49:30 GMT
Repository: hbase
Updated Branches:
  refs/heads/master 552400e53 -> 8855670cd


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/master
Commit: 8855670cd701fdf9c2ab41907f9525d122608e6d
Parents: 552400e
Author: tedyu <yuzhihong@gmail.com>
Authored: Mon Sep 12 15:49:23 2016 -0700
Committer: tedyu <yuzhihong@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) {


Mime
View raw message