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 d57f2b9dea
commit a4bb56b93b
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

@ -78,6 +78,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

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 {
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.");