Fix NullPointerException in blockReportCompleted
@@ -5635,6 +5635,7 @@ public void blockReportCompleted(final DatanodeID nodeID, DatanodeStorage[] stor
if (success) {
DatanodeDescriptor node = datanodeManager.getDatanode(nodeID);
+ if (node != null) {
for (DatanodeStorage storage : storages) {
DatanodeStorageInfo storageInfo = node.getStorageInfo(storage.getStorageID());
storageInfo.receivedBlockReport();
@@ -5642,3 +5643,4 @@ public void blockReportCompleted(final DatanodeID nodeID, DatanodeStorage[] stor
}
}
}
+}
