diff --git a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/SCMContainerManager.java b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/SCMContainerManager.java index 374772d155..2615289f43 100644 --- a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/SCMContainerManager.java +++ b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/SCMContainerManager.java @@ -190,7 +190,7 @@ public class SCMContainerManager implements ContainerManager { Collections.sort(containersIds); return containersIds.stream() - .filter(id -> id.getId() > startId) + .filter(id -> id.getId() >= startId) .limit(count) .map(id -> { try {