HBASE-16220 Demote log level for "HRegionFileSystem - No StoreFiles for" messages to TRACE
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/7c4c51f2 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/7c4c51f2 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/7c4c51f2 Branch: refs/heads/branch-1 Commit: 7c4c51f2c712a290fa3b0bd8cade193026069567 Parents: 16be7bb Author: Andrew Purtell <[email protected]> Authored: Tue Jul 12 15:44:06 2016 -0700 Committer: Andrew Purtell <[email protected]> Committed: Tue Jul 12 17:00:09 2016 -0700 ---------------------------------------------------------------------- .../hbase/regionserver/HRegionFileSystem.java | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/7c4c51f2/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionFileSystem.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionFileSystem.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionFileSystem.java index 397ae7b..24b485d 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionFileSystem.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionFileSystem.java @@ -198,7 +198,9 @@ public class HRegionFileSystem { Path familyDir = getStoreDir(familyName); FileStatus[] files = FSUtils.listStatus(this.fs, familyDir); if (files == null) { - LOG.debug("No StoreFiles for: " + familyDir); + if (LOG.isTraceEnabled()) { + LOG.trace("No StoreFiles for: " + familyDir); + } return null; } @@ -378,7 +380,9 @@ public class HRegionFileSystem { if (!fs.exists(buildPath)) { 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. if (!rename(buildPath, 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, int hdfsClientRetriesNumber) throws InterruptedException { if (sleepMultiplier > hdfsClientRetriesNumber) { - LOG.debug(msg + ", retries exhausted"); + if (LOG.isDebugEnabled()) { + LOG.debug(msg + ", retries exhausted"); + } return; } - LOG.debug(msg + ", sleeping " + baseSleepBeforeRetries + " times " + sleepMultiplier); + if (LOG.isDebugEnabled()) { + LOG.debug(msg + ", sleeping " + baseSleepBeforeRetries + " times " + sleepMultiplier); + } Thread.sleep((long)baseSleepBeforeRetries * sleepMultiplier); } }
