|
@@ -3722,7 +3722,7 @@ public class BlockManager {
|
|
|
private void removeFromExcessReplicateMap(Block block) {
|
|
|
for (DatanodeStorageInfo info : blocksMap.getStorages(block)) {
|
|
|
String uuid = info.getDatanodeDescriptor().getDatanodeUuid();
|
|
|
- LightWeightLinkedSet<Block> excessReplicas = excessReplicateMap.get(uuid);
|
|
|
+ LightWeightLinkedSet<BlockInfo> excessReplicas = excessReplicateMap.get(uuid);
|
|
|
if (excessReplicas != null) {
|
|
|
if (excessReplicas.remove(block)) {
|
|
|
excessBlocksCount.decrementAndGet();
|