|
@@ -60,8 +60,10 @@ class CorruptReplicasMap{
|
|
|
"on " + dn.getName() +
|
|
|
" by " + Server.getRemoteIp());
|
|
|
}
|
|
|
- NameNode.getNameNodeMetrics().numBlocksCorrupted.set(
|
|
|
+ if (NameNode.getNameNodeMetrics() != null) {
|
|
|
+ NameNode.getNameNodeMetrics().numBlocksCorrupted.set(
|
|
|
corruptReplicasMap.size());
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -72,8 +74,10 @@ class CorruptReplicasMap{
|
|
|
void removeFromCorruptReplicasMap(Block blk) {
|
|
|
if (corruptReplicasMap != null) {
|
|
|
corruptReplicasMap.remove(blk);
|
|
|
- NameNode.getNameNodeMetrics().numBlocksCorrupted.set(
|
|
|
+ if (NameNode.getNameNodeMetrics() != null) {
|
|
|
+ NameNode.getNameNodeMetrics().numBlocksCorrupted.set(
|
|
|
corruptReplicasMap.size());
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
|