clear excessReplicateMap before processing the miss-replicated blocks
@@ -3307,6 +3307,7 @@ public void processMisReplicatedBlocks() throws IOException {
//this would only result in these block getting transiantly over replicated
HdfsVariables.resetMisReplicatedIndex();
neededReplications.clear();
+ excessReplicateMap.clear();
}
replicationQueuesInitializer = new Daemon() {
