|
@@ -3584,13 +3584,12 @@ public class BlockManager {
|
|
|
String src, BlockInfo[] blocks) {
|
|
|
for (BlockInfo b: blocks) {
|
|
|
if (!b.isComplete()) {
|
|
|
- final BlockInfoContiguousUnderConstruction uc =
|
|
|
- (BlockInfoContiguousUnderConstruction)b;
|
|
|
final int numNodes = b.numNodes();
|
|
|
- LOG.info("BLOCK* " + b + " is not COMPLETE (ucState = "
|
|
|
- + uc.getBlockUCState() + ", replication# = " + numNodes
|
|
|
- + (numNodes < minReplication ? " < ": " >= ")
|
|
|
- + " minimum = " + minReplication + ") in file " + src);
|
|
|
+ final int min = getMinStorageNum(b);
|
|
|
+ final BlockUCState state = b.getBlockUCState();
|
|
|
+ LOG.info("BLOCK* " + b + " is not COMPLETE (ucState = " + state
|
|
|
+ + ", replication# = " + numNodes + (numNodes < min ? " < " : " >= ")
|
|
|
+ + " minimum = " + min + ") in file " + src);
|
|
|
return false;
|
|
|
}
|
|
|
}
|