HDFS-14624. When decommissioning a node, log remaining blocks to replicate periodically. Contributed by Stephen O'Donnell.
(cherry picked from commit 5747f6cff5
)
This commit is contained in:
parent
f14fb9081f
commit
21a89d544f
|
@ -507,8 +507,10 @@ public class DatanodeAdminManager {
|
|||
namesystem.writeUnlock();
|
||||
}
|
||||
if (numBlocksChecked + numNodesChecked > 0) {
|
||||
LOG.info("Checked {} blocks and {} nodes this tick", numBlocksChecked,
|
||||
numNodesChecked);
|
||||
LOG.info("Checked {} blocks and {} nodes this tick. {} nodes are now " +
|
||||
"in maintenance or transitioning state. {} nodes pending.",
|
||||
numBlocksChecked, numNodesChecked, outOfServiceNodeBlocks.size(),
|
||||
pendingNodes.size());
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -599,14 +601,14 @@ public class DatanodeAdminManager {
|
|||
LOG.debug("Node {} is sufficiently replicated and healthy, "
|
||||
+ "marked as {}.", dn, dn.getAdminState());
|
||||
} else {
|
||||
LOG.debug("Node {} {} healthy."
|
||||
LOG.info("Node {} {} healthy."
|
||||
+ " It needs to replicate {} more blocks."
|
||||
+ " {} is still in progress.", dn,
|
||||
isHealthy ? "is": "isn't", blocks.size(), dn.getAdminState());
|
||||
}
|
||||
} else {
|
||||
LOG.debug("Node {} still has {} blocks to replicate "
|
||||
+ "before it is a candidate to finish {}.",
|
||||
LOG.info("Node {} still has {} blocks to replicate "
|
||||
+ "before it is a candidate to finish {}.",
|
||||
dn, blocks.size(), dn.getAdminState());
|
||||
}
|
||||
} catch (Exception e) {
|
||||
|
|
Loading…
Reference in New Issue