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

HDFS-15873. Add namenode address in logs for block report (#2743) 

(cherry picked from commit 6a922f9896)
(cherry picked from commit 2f56e2b54d)
This commit is contained in:
litao 2021-03-09 00:50:51 +08:00 committed by Wei-Chiu Chuang
parent 2ba3890b15
commit 6df2dc8463
No known key found for this signature in database
GPG Key ID: B362E1C021854B9D
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPServiceActor.java
View File

@ -423,7 +423,8 @@ class BPServiceActor implements Runnable {
final int nCmds = cmds.size(); final int nCmds = cmds.size();
LOG.info((success ? "S" : "Uns") + LOG.info((success ? "S" : "Uns") +
"uccessfully sent block report 0x" + "uccessfully sent block report 0x" +
Long.toHexString(reportId) + ", containing " + reports.length + Long.toHexString(reportId) + " to namenode: " + nnAddr +
", containing " + reports.length +
" storage report(s), of which we sent " + numReportsSent + "." + " storage report(s), of which we sent " + numReportsSent + "." +
" The reports had " + totalBlockCount + " The reports had " + totalBlockCount +
" total blocks and used " + numRPCs + " total blocks and used " + numRPCs +
@ -934,10 +935,12 @@ class BPServiceActor implements Runnable {
void triggerBlockReport(BlockReportOptions options) { void triggerBlockReport(BlockReportOptions options) {
if (options.isIncremental()) { if (options.isIncremental()) {
LOG.info(bpos.toString() + ": scheduling an incremental block report."); LOG.info(bpos.toString() + ": scheduling an incremental block report " +
"to namenode: " + nnAddr + ".");
ibrManager.triggerIBR(true); ibrManager.triggerIBR(true);
} else { } else {
LOG.info(bpos.toString() + ": scheduling a full block report."); LOG.info(bpos.toString() + ": scheduling a full block report " +
"to namenode: " + nnAddr + ".");
synchronized(ibrManager) { synchronized(ibrManager) {
scheduler.forceFullBlockReportNow(); scheduler.forceFullBlockReportNow();
ibrManager.notifyAll(); ibrManager.notifyAll();