Skip to content

Commit 10b8494

Browse files
committed
change fullBrLeaseId to lease ID
1 parent e6023ce commit 10b8494

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2765,7 +2765,7 @@ public boolean processReport(final DatanodeID nodeID,
27652765
if (namesystem.isInStartupSafeMode()
27662766
&& !StorageType.PROVIDED.equals(storageInfo.getStorageType())
27672767
&& storageInfo.getBlockReportCount() > 0) {
2768-
blockLog.info("BLOCK* processReport 0x{} with fullBrLeaseId 0x{}: "
2768+
blockLog.info("BLOCK* processReport 0x{} with lease ID 0x{}: "
27692769
+ "discarded non-initial block report from {}"
27702770
+ " because namenode still in startup phase",
27712771
strBlockReportId, fullBrLeaseId, nodeID);
@@ -2776,7 +2776,7 @@ public boolean processReport(final DatanodeID nodeID,
27762776
if (storageInfo.getBlockReportCount() == 0) {
27772777
// The first block report can be processed a lot more efficiently than
27782778
// ordinary block reports. This shortens restart times.
2779-
blockLog.info("BLOCK* processReport 0x{} with fullBrLeaseId 0x{}: Processing first "
2779+
blockLog.info("BLOCK* processReport 0x{} with lease ID 0x{}: Processing first "
27802780
+ "storage report for {} from datanode {}",
27812781
strBlockReportId, fullBrLeaseId,
27822782
storageInfo.getStorageID(),
@@ -2797,7 +2797,7 @@ public boolean processReport(final DatanodeID nodeID,
27972797

27982798
if(blockLog.isDebugEnabled()) {
27992799
for (Block b : invalidatedBlocks) {
2800-
blockLog.debug("BLOCK* processReport 0x{} with fullBrLeaseId 0x{}: {} on node {} size {} " +
2800+
blockLog.debug("BLOCK* processReport 0x{} with lease ID 0x{}: {} on node {} size {} " +
28012801
"does not belong to any file.", strBlockReportId, fullBrLeaseId, b,
28022802
node, b.getNumBytes());
28032803
}
@@ -2808,7 +2808,7 @@ public boolean processReport(final DatanodeID nodeID,
28082808
if (metrics != null) {
28092809
metrics.addStorageBlockReport((int) (endTime - startTime));
28102810
}
2811-
blockLog.info("BLOCK* processReport 0x{} with fullBrLeaseId 0x{}: from storage {} node {}, " +
2811+
blockLog.info("BLOCK* processReport 0x{} with lease ID 0x{}: from storage {} node {}, " +
28122812
"blocks: {}, hasStaleStorage: {}, processing time: {} msecs, " +
28132813
"invalidatedBlocks: {}", strBlockReportId, fullBrLeaseId, storage.getStorageID(),
28142814
nodeID, newReport.getNumberOfBlocks(),

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -456,7 +456,7 @@ List<DatanodeCommand> blockReport(long fullBrLeaseId) throws IOException {
456456
final int nCmds = cmds.size();
457457
LOG.info((success ? "S" : "Uns") +
458458
"uccessfully sent block report 0x" + Long.toHexString(reportId) +
459-
" with fullBrLeaseId 0x" + Long.toHexString(fullBrLeaseId) + " to namenode: " + nnAddr +
459+
" with lease ID 0x" + Long.toHexString(fullBrLeaseId) + " to namenode: " + nnAddr +
460460
", containing " + reports.length +
461461
" storage report(s), of which we sent " + numReportsSent + "." +
462462
" The reports had " + totalBlockCount +

0 commit comments

Comments
 (0)