You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java
+3-3
Original file line number
Diff line number
Diff line change
@@ -2909,7 +2909,7 @@ public boolean processReport(final DatanodeID nodeID,
2909
2909
+ "discarded non-initial block report from {}"
2910
2910
+ " because namenode still in startup phase",
2911
2911
strBlockReportId, fullBrLeaseId, nodeID);
2912
-
removeLease(node);
2912
+
removeDNLeaseIfNeeded(node);
2913
2913
return !node.hasStaleStorages();
2914
2914
}
2915
2915
@@ -2957,8 +2957,8 @@ public boolean processReport(final DatanodeID nodeID,
2957
2957
return !node.hasStaleStorages();
2958
2958
}
2959
2959
2960
-
// Remove the lease when we have received block reports for all storages for a particular DN.
2961
-
voidremoveLease(DatanodeDescriptornode) {
2960
+
// Remove the DN lease only when we have received block reports for all storages for a particular DN.
0 commit comments