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 20:01:11 UTC
[hbase] branch branch-1.3 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.3
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-1.3 by this push:
new 70681fc HBASE-23250 Log message about CleanerChore delegate initialization should be at INFO
70681fc is described below
commit 70681fcb83f1dc1c0e5379923e17aa7a8deabf0f
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 7d38ddb..8df7ff1 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
@@ -247,7 +247,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);
}
}
@@ -350,7 +350,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);
@@ -360,10 +360,10 @@ public abstract class CleanerChore<T extends FileCleanerDelegate> extends Schedu
}
}
}
-
+
deletableValidFiles = filteredFiles;
}
-
+
Iterable<FileStatus> filesToDelete = Iterables.concat(invalidFiles, deletableValidFiles);
return deleteFiles(filesToDelete) == files.size();
}