You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by jy...@apache.org on 2012/11/27 16:41:43 UTC
svn commit: r1414229 - in
/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner:
CleanerChore.java TimeToLiveHFileCleaner.java
Author: jyates
Date: Tue Nov 27 15:41:41 2012
New Revision: 1414229
URL: http://svn.apache.org/viewvc?rev=1414229&view=rev
Log:
HBASE-7214: CleanerChore logs too much, so much so it obscures all else that is going on
Modified:
hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/CleanerChore.java
hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/TimeToLiveHFileCleaner.java
Modified: hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/CleanerChore.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/CleanerChore.java?rev=1414229&r1=1414228&r2=1414229&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/CleanerChore.java (original)
+++ hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/CleanerChore.java Tue Nov 27 15:41:41 2012
@@ -146,7 +146,9 @@ public abstract class CleanerChore<T ext
* @throws IOException if there is an unexpected filesystem error
*/
private boolean checkAndDeleteDirectory(Path toCheck) throws IOException {
- LOG.debug("Checking directory: " + toCheck);
+ if (LOG.isTraceEnabled()) {
+ LOG.trace("Checking directory: " + toCheck);
+ }
FileStatus[] children = FSUtils.listStatus(fs, toCheck);
// if the directory doesn't exist, then we are done
if (children == null) return true;
@@ -200,12 +202,16 @@ public abstract class CleanerChore<T ext
if (!cleaner.isFileDeletable(filePath)) {
// this file is not deletable, then we are done
- LOG.debug(filePath + " is not deletable according to:" + cleaner);
+ if (LOG.isTraceEnabled()) {
+ LOG.trace(filePath + " is not deletable according to:" + cleaner);
+ }
return false;
}
}
// delete this file if it passes all the cleaners
- LOG.debug("Removing: " + filePath + " from archive");
+ if (LOG.isTraceEnabled()) {
+ LOG.trace("Removing: " + filePath + " from archive");
+ }
boolean success = this.fs.delete(filePath, false);
if (!success) {
LOG.warn("Attempted to delete:" + filePath
Modified: hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/TimeToLiveHFileCleaner.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/TimeToLiveHFileCleaner.java?rev=1414229&r1=1414228&r2=1414229&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/TimeToLiveHFileCleaner.java (original)
+++ hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/TimeToLiveHFileCleaner.java Tue Nov 27 15:41:41 2012
@@ -65,7 +65,10 @@ public class TimeToLiveHFileCleaner exte
return false;
}
long life = currentTime - time;
- LOG.debug("Life:" + life + ", ttl:" + ttl + ", current:" + currentTime + ", from: " + time);
+ if (LOG.isTraceEnabled()) {
+ LOG.trace("HFile life:" + life + ", ttl:" + ttl + ", current:" + currentTime + ", from: "
+ + time);
+ }
if (life < 0) {
LOG.warn("Found a log (" + filePath + ") newer than current time (" + currentTime + " < "
+ time + "), probably a clock skew");