|
@@ -2866,6 +2866,9 @@ public class BlockManager implements BlockStatsMXBean {
|
|
|
|
|
|
if(storedBlock.getBlockUCState() == BlockUCState.COMMITTED &&
|
|
|
hasMinStorage(storedBlock, numLiveReplicas)) {
|
|
|
+ if (!bc.isStriped()) {
|
|
|
+ addExpectedReplicasToPending(storedBlock);
|
|
|
+ }
|
|
|
completeBlock(storedBlock, false);
|
|
|
} else if (storedBlock.isComplete() && result == AddBlockResult.ADDED) {
|
|
|
// check whether safe replication is reached for the block
|