ZanderXu commented on PR #5583:
URL: https://github.com/apache/hadoop/pull/5583#issuecomment-1519702401
`blockManager.processAllPendingDNMessages()` should check if the pended
message is a redundant report request. If it is, namenode shouldn't mark this
replica as a corrupted replica.
```
for (BlockToMarkCorrupt b : toCorrupt) {
if (!removeInvalidCorruptedBlocks) {
markBlockAsCorrupt(b, storageInfo, node);
} else {
// Try to remove this corrupted replica directly if this storage has
reported
// a healthy replica. This logic is same with addStoredBlock.
DatanodeStorageInfo otherStorage =
b.getStored().findStorageInfo(node);
boolean alreadyExist = otherStorage == storageInfo;
if (alreadyExist) {
blockLog.info("BLOCK* processAndHandleReportedBlock: Redundant
report request " +
"received for {} on node {} with status {} and size {}.",
b.getStored(), node,
b.getCorrupted(), b.getCorrupted().getNumBytes());
} else {
markBlockAsCorrupt(b, storageInfo, node);
}
}
}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
