diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/HFileCleaner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/HFileCleaner.java index f20dcc42459..640c8f794fc 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/HFileCleaner.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/HFileCleaner.java @@ -231,7 +231,7 @@ public class HFileCleaner extends CleanerChore { try { task = queue.take(); } catch (InterruptedException e) { - LOG.debug("Interrupted while trying to take a task from queue", e); + LOG.trace("Interrupted while trying to take a task from queue", e); break; } if (task != null) { @@ -445,4 +445,12 @@ public class HFileCleaner extends CleanerChore { } return updated; } + + @Override + public synchronized void cancel(boolean mayInterruptIfRunning) { + super.cancel(mayInterruptIfRunning); + for (Thread t: this.threads) { + t.interrupt(); + } + } }