You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2018/01/19 19:48:36 UTC
hbase git commit: HBASE-19822 Override cancel(boolean) in LogCleaner
(Addendum)
Repository: hbase
Updated Branches:
refs/heads/branch-2 c01dc6912 -> 3131234ff
HBASE-19822 Override cancel(boolean) in LogCleaner (Addendum)
Signed-off-by: Michael Stack <st...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/3131234f
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/3131234f
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/3131234f
Branch: refs/heads/branch-2
Commit: 3131234ffd03ed639f0edc8460506e04c5c57d10
Parents: c01dc69
Author: Reid Chan <re...@outlook.com>
Authored: Fri Jan 19 10:49:28 2018 +0800
Committer: Michael Stack <st...@apache.org>
Committed: Fri Jan 19 11:48:16 2018 -0800
----------------------------------------------------------------------
.../org/apache/hadoop/hbase/master/cleaner/LogCleaner.java | 8 ++++++++
1 file changed, 8 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/3131234f/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/LogCleaner.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/LogCleaner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/LogCleaner.java
index 6e5424f..db364ee 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/LogCleaner.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/LogCleaner.java
@@ -177,6 +177,14 @@ public class LogCleaner extends CleanerChore<BaseLogCleanerDelegate> {
}
}
+ @Override
+ public synchronized void cancel(boolean mayInterruptIfRunning) {
+ super.cancel(mayInterruptIfRunning);
+ for (Thread t : oldWALsCleaner) {
+ t.interrupt();
+ }
+ }
+
private static final class CleanerContext {
// At most waits 60 seconds
static final long MAX_WAIT = 60 * 1000;