You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ja...@apache.org on 2019/11/05 19:52:27 UTC
[hbase] branch branch-1 updated: HBASE-23250 Log message about
CleanerChore delegate initialization should be at INFO
This is an automated email from the ASF dual-hosted git repository.
janh pushed a commit to branch branch-1
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-1 by this push:
new 1360816 HBASE-23250 Log message about CleanerChore delegate initialization should be at INFO
1360816 is described below
commit 13608167866dcaff02218952373ac02f252c94f5
Author: ravowlga123 <ra...@gmail.com>
AuthorDate: Tue Nov 5 20:21:16 2019 +0100
HBASE-23250 Log message about CleanerChore delegate initialization should be at INFO
Signed-off-by: Jan Hentschel <ja...@ultratendency.com>
---
.../java/org/apache/hadoop/hbase/master/cleaner/CleanerChore.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/CleanerChore.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/CleanerChore.java
index 78be50b..50cd980 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/CleanerChore.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/CleanerChore.java
@@ -150,7 +150,7 @@ public abstract class CleanerChore<T extends FileCleanerDelegate> extends Schedu
for (String className : logCleaners) {
T logCleaner = newFileCleaner(className, conf);
if (logCleaner != null) {
- LOG.debug("initialize cleaner=" + className);
+ LOG.info("initialize cleaner=" + className);
this.cleanersChain.add(logCleaner);
}
}
@@ -254,7 +254,7 @@ public abstract class CleanerChore<T extends FileCleanerDelegate> extends Schedu
}
Iterable<FileStatus> filteredFiles = cleaner.getDeletableFiles(deletableValidFiles);
-
+
// trace which cleaner is holding on to each file
if (LOG.isTraceEnabled()) {
ImmutableSet<FileStatus> filteredFileSet = ImmutableSet.copyOf(filteredFiles);
@@ -264,10 +264,10 @@ public abstract class CleanerChore<T extends FileCleanerDelegate> extends Schedu
}
}
}
-
+
deletableValidFiles = filteredFiles;
}
-
+
Iterable<FileStatus> filesToDelete = Iterables.concat(invalidFiles, deletableValidFiles);
return deleteFiles(filesToDelete) == files.size();
}