Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-16220 Demote log level for "HRegionFileSystem - No StoreFiles for" messages to TRACE

This commit is contained in:
Andrew Purtell 2016-07-12 15:44:06 -07:00
parent 16be7bba53
commit 7c4c51f2c7
1 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionFileSystem.java
View File

@ -198,7 +198,9 @@ public class HRegionFileSystem {
Path familyDir = getStoreDir(familyName); Path familyDir = getStoreDir(familyName);
FileStatus[] files = FSUtils.listStatus(this.fs, familyDir); FileStatus[] files = FSUtils.listStatus(this.fs, familyDir);
if (files == null) { if (files == null) {
LOG.debug("No StoreFiles for: " + familyDir); if (LOG.isTraceEnabled()) {
LOG.trace("No StoreFiles for: " + familyDir);
}
return null; return null;
} }
@ -378,7 +380,9 @@ public class HRegionFileSystem {
if (!fs.exists(buildPath)) { if (!fs.exists(buildPath)) {
throw new FileNotFoundException(buildPath.toString()); throw new FileNotFoundException(buildPath.toString());
} }
LOG.debug("Committing store file " + buildPath + " as " + dstPath); if (LOG.isDebugEnabled()) {
LOG.debug("Committing store file " + buildPath + " as " + dstPath);
}
// buildPath exists, therefore not doing an exists() check. // buildPath exists, therefore not doing an exists() check.
if (!rename(buildPath, dstPath)) { if (!rename(buildPath, dstPath)) {
throw new IOException("Failed rename of " + buildPath + " to " + dstPath); throw new IOException("Failed rename of " + buildPath + " to " + dstPath);
@ -1083,10 +1087,14 @@ public class HRegionFileSystem {
private static void sleepBeforeRetry(String msg, int sleepMultiplier, int baseSleepBeforeRetries, private static void sleepBeforeRetry(String msg, int sleepMultiplier, int baseSleepBeforeRetries,
int hdfsClientRetriesNumber) throws InterruptedException { int hdfsClientRetriesNumber) throws InterruptedException {
if (sleepMultiplier > hdfsClientRetriesNumber) { if (sleepMultiplier > hdfsClientRetriesNumber) {
LOG.debug(msg + ", retries exhausted"); if (LOG.isDebugEnabled()) {
LOG.debug(msg + ", retries exhausted");
}
return; return;
} }
LOG.debug(msg + ", sleeping " + baseSleepBeforeRetries + " times " + sleepMultiplier); if (LOG.isDebugEnabled()) {
LOG.debug(msg + ", sleeping " + baseSleepBeforeRetries + " times " + sleepMultiplier);
}
Thread.sleep((long)baseSleepBeforeRetries * sleepMultiplier); Thread.sleep((long)baseSleepBeforeRetries * sleepMultiplier);
} }
} }