HDFS-9434. Recommission a datanode with 500k blocks may pause NN for 30 seconds for printing info log messags.
This commit is contained in:
parent
0664782025
commit
bf82a8de30
|
@ -1474,6 +1474,9 @@ Release 2.8.0 - UNRELEASED
|
||||||
HDFS-9400. TestRollingUpgradeRollback fails on branch-2.
|
HDFS-9400. TestRollingUpgradeRollback fails on branch-2.
|
||||||
(Brahma Reddy Battula via cnauroth)
|
(Brahma Reddy Battula via cnauroth)
|
||||||
|
|
||||||
|
HDFS-9434. Recommission a datanode with 500k blocks may pause NN for 30
|
||||||
|
seconds for printing info log messags. (szetszwo)
|
||||||
|
|
||||||
Release 2.7.3 - UNRELEASED
|
Release 2.7.3 - UNRELEASED
|
||||||
|
|
||||||
INCOMPATIBLE CHANGES
|
INCOMPATIBLE CHANGES
|
||||||
|
|
|
@ -2926,11 +2926,9 @@ public class BlockManager implements BlockStatsMXBean {
|
||||||
for(DatanodeStorageInfo storage : blocksMap.getStorages(block, State.NORMAL)) {
|
for(DatanodeStorageInfo storage : blocksMap.getStorages(block, State.NORMAL)) {
|
||||||
final DatanodeDescriptor cur = storage.getDatanodeDescriptor();
|
final DatanodeDescriptor cur = storage.getDatanodeDescriptor();
|
||||||
if (storage.areBlockContentsStale()) {
|
if (storage.areBlockContentsStale()) {
|
||||||
LOG.info("BLOCK* processOverReplicatedBlock: " +
|
LOG.trace("BLOCK* processOverReplicatedBlock: Postponing {}"
|
||||||
"Postponing processing of over-replicated " +
|
+ " since storage {} does not yet have up-to-date information.",
|
||||||
block + " since storage + " + storage
|
block, storage);
|
||||||
+ "datanode " + cur + " does not yet have up-to-date " +
|
|
||||||
"block information.");
|
|
||||||
postponeBlock(block);
|
postponeBlock(block);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue