diff --git a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/states/ContainerStateMap.java b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/states/ContainerStateMap.java index c254dd723e5c..de507b7571d3 100644 --- a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/states/ContainerStateMap.java +++ b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/states/ContainerStateMap.java @@ -147,6 +147,7 @@ public void removeContainer(final ContainerID id) { ownerMap.remove(info.getOwner(), id); repConfigMap.remove(info.getReplicationConfig(), id); typeMap.remove(info.getReplicationType(), id); + replicaMap.remove(id); // Flush the cache of this container type. flushCache(info); LOG.trace("Container {} removed from ContainerStateMap.", id);