HDFS-10525. Fix NPE in CacheReplicationMonitor#rescanCachedBlockMap (Xiao Chen via cmccabe)
(cherry picked from commit 2ca73445f5
)
This commit is contained in:
parent
17301ab395
commit
8280e3bcc2
|
@ -502,6 +502,14 @@ public class CacheReplicationMonitor extends Thread implements Closeable {
|
|||
CachedBlock cblock = it.next();
|
||||
BlockInfo blockInfo = blockManager.
|
||||
getStoredBlock(new Block(cblock.getBlockId()));
|
||||
if (blockInfo == null) {
|
||||
// Cannot find this block on the NameNode, skip this block from
|
||||
// capacity calculation. Later logic will handle this block.
|
||||
LOG.debug("Block {}: cannot be found in block manager and hence"
|
||||
+ " skipped from calculation for node {}.", cblock.getBlockId(),
|
||||
dn.getDatanodeUuid());
|
||||
continue;
|
||||
}
|
||||
if (blockInfo.getNumBytes() > remaining) {
|
||||
LOG.debug("Block {}: removing from PENDING_CACHED for node {} "
|
||||
+ "because it cannot fit in remaining cache size {}.",
|
||||
|
|
Loading…
Reference in New Issue