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

HDFS-7258. CacheReplicationMonitor rescan schedule log should use DEBUG level instead of INFO level. Contributed by Xiaoyu Yao.

This commit is contained in:
Haohui Mai 2014-10-23 23:57:56 -07:00
parent 071c925c7d
commit 0942c99eba
2 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt
View File

@ -334,6 +334,9 @@ Release 2.7.0 - UNRELEASED
HDFS-7232. Populate hostname in httpfs audit log (Zoran Dimitrijevic HDFS-7232. Populate hostname in httpfs audit log (Zoran Dimitrijevic
via aw) 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 Release 2.6.0 - UNRELEASED
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES

12
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/CacheReplicationMonitor.java
View File

@ -166,17 +166,16 @@ public class CacheReplicationMonitor extends Thread implements Closeable {
try { try {
while (true) { while (true) {
if (shutdown) { if (shutdown) {
LOG.info("Shutting down CacheReplicationMonitor"); LOG.debug("Shutting down CacheReplicationMonitor");
return; return;
} }
if (completedScanCount < neededScanCount) { if (completedScanCount < neededScanCount) {
LOG.info("Rescanning because of pending operations"); LOG.debug("Rescanning because of pending operations");
break; break;
} }
long delta = (startTimeMs + intervalMs) - curTimeMs; long delta = (startTimeMs + intervalMs) - curTimeMs;
if (delta <= 0) { if (delta <= 0) {
LOG.info("Rescanning after " + (curTimeMs - startTimeMs) + LOG.debug("Rescanning after {} milliseconds", (curTimeMs - startTimeMs));
" milliseconds");
break; break;
} }
doRescan.await(delta, TimeUnit.MILLISECONDS); doRescan.await(delta, TimeUnit.MILLISECONDS);
@ -198,9 +197,8 @@ public class CacheReplicationMonitor extends Thread implements Closeable {
} finally { } finally {
lock.unlock(); lock.unlock();
} }
LOG.info("Scanned " + scannedDirectives + " directive(s) and " + LOG.debug("Scanned {} directive(s) and {} block(s) in {} millisecond(s).",
scannedBlocks + " block(s) in " + (curTimeMs - startTimeMs) + " " + scannedDirectives, scannedBlocks, (curTimeMs - startTimeMs));
"millisecond(s).");
} }
} catch (InterruptedException e) { } catch (InterruptedException e) {
LOG.info("Shutting down CacheReplicationMonitor."); LOG.info("Shutting down CacheReplicationMonitor.");