diff --git a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/ReplicationManager.java b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/ReplicationManager.java index a010910fe8b2..bab885173627 100644 --- a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/ReplicationManager.java +++ b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/ReplicationManager.java @@ -746,8 +746,9 @@ private void handleOverReplicatedContainer(final ContainerInfo container, if (excess > 0) { sendDeleteCommand(container, r.getDatanodeDetails(), true); excess -= 1; + } else { + break; } - break; } // After removing all unhealthy replicas, if the container is still over // replicated then we need to check if it is already mis-replicated.