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 f292048ffd
commit 911706a873
1 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -199,7 +199,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;
} }
@ -379,7 +381,9 @@ public class HRegionFileSystem {
if (!fs.exists(buildPath)) { if (!fs.exists(buildPath)) {
throw new FileNotFoundException(buildPath.toString()); throw new FileNotFoundException(buildPath.toString());
} }
if (LOG.isDebugEnabled()) {
LOG.debug("Committing store file " + buildPath + " as " + dstPath); 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);
@ -1082,10 +1086,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) {
if (LOG.isDebugEnabled()) {
LOG.debug(msg + ", retries exhausted"); LOG.debug(msg + ", retries exhausted");
}
return; return;
} }
if (LOG.isDebugEnabled()) {
LOG.debug(msg + ", sleeping " + baseSleepBeforeRetries + " times " + sleepMultiplier); LOG.debug(msg + ", sleeping " + baseSleepBeforeRetries + " times " + sleepMultiplier);
}
Thread.sleep((long)baseSleepBeforeRetries * sleepMultiplier); Thread.sleep((long)baseSleepBeforeRetries * sleepMultiplier);
} }
} }