diff --git a/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt b/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt index 090befc2f18..7975c435335 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt +++ b/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt @@ -334,6 +334,9 @@ Release 2.7.0 - UNRELEASED HDFS-7232. Populate hostname in httpfs audit log (Zoran Dimitrijevic via aw) + HDFS-7258. CacheReplicationMonitor rescan schedule log should use DEBUG + level instead of INFO level. (Xiaoyu Yao via wheat9) + Release 2.6.0 - UNRELEASED INCOMPATIBLE CHANGES diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/CacheReplicationMonitor.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/CacheReplicationMonitor.java index fa5083ca6e0..a0f35039e47 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/CacheReplicationMonitor.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/CacheReplicationMonitor.java @@ -166,17 +166,16 @@ public class CacheReplicationMonitor extends Thread implements Closeable { try { while (true) { if (shutdown) { - LOG.info("Shutting down CacheReplicationMonitor"); + LOG.debug("Shutting down CacheReplicationMonitor"); return; } if (completedScanCount < neededScanCount) { - LOG.info("Rescanning because of pending operations"); + LOG.debug("Rescanning because of pending operations"); break; } long delta = (startTimeMs + intervalMs) - curTimeMs; if (delta <= 0) { - LOG.info("Rescanning after " + (curTimeMs - startTimeMs) + - " milliseconds"); + LOG.debug("Rescanning after {} milliseconds", (curTimeMs - startTimeMs)); break; } doRescan.await(delta, TimeUnit.MILLISECONDS); @@ -198,9 +197,8 @@ public class CacheReplicationMonitor extends Thread implements Closeable { } finally { lock.unlock(); } - LOG.info("Scanned " + scannedDirectives + " directive(s) and " + - scannedBlocks + " block(s) in " + (curTimeMs - startTimeMs) + " " + - "millisecond(s)."); + LOG.debug("Scanned {} directive(s) and {} block(s) in {} millisecond(s).", + scannedDirectives, scannedBlocks, (curTimeMs - startTimeMs)); } } catch (InterruptedException e) { LOG.info("Shutting down CacheReplicationMonitor.");