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-17256 Rpc handler monitoring will be removed when the task queue is full (Guangxu Cheng)
Date Mon, 05 Dec 2016 20:14:25 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1 600fa8de7 -> c2801a2ea


HBASE-17256 Rpc handler monitoring will be removed when the task queue is full (Guangxu Cheng)


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

Branch: refs/heads/branch-1
Commit: c2801a2ea87a870195557122ede08095f15b19c1
Parents: 600fa8d
Author: tedyu <yuzhihong@gmail.com>
Authored: Mon Dec 5 12:14:20 2016 -0800
Committer: tedyu <yuzhihong@gmail.com>
Committed: Mon Dec 5 12:14:20 2016 -0800

----------------------------------------------------------------------
 .../main/java/org/apache/hadoop/hbase/monitoring/TaskMonitor.java | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/c2801a2e/hbase-server/src/main/java/org/apache/hadoop/hbase/monitoring/TaskMonitor.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/monitoring/TaskMonitor.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/monitoring/TaskMonitor.java
index b620fac..c8e0a39 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/monitoring/TaskMonitor.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/monitoring/TaskMonitor.java
@@ -73,6 +73,9 @@ public class TaskMonitor {
         new Class<?>[] { MonitoredTask.class },
         new PassthroughInvocationHandler<MonitoredTask>(stat));
     TaskAndWeakRefPair pair = new TaskAndWeakRefPair(stat, proxy);
+    if (tasks.isFull()) {
+      purgeExpiredTasks();
+    }
     tasks.add(pair);
     return proxy;
   }


Mime
View raw message