big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

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

Browse Source 
(cherry picked from commit 6a922f9896)
This commit is contained in:
litao 2021-03-09 00:50:51 +08:00 committed by Wei-Chiu Chuang
parent 3f9c9ccf46
commit 2f56e2b54d
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

@ -436,7 +436,8 @@ List<DatanodeCommand> blockReport(long fullBrLeaseId) throws IOException {
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 +
@ -930,10 +931,12 @@ void reRegister() throws IOException {
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();