This is an automated email from the ASF dual-hosted git repository. nanda pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push: new 4f7d32e HDDS-1081. CLOSING state containers should not be added to pipeline on SCM start. Contributed by Lokesh Jain. 4f7d32e is described below commit 4f7d32edf8c0e9d81809b9b881f421bb7428406a Author: Nanda kumar <na...@apache.org> AuthorDate: Tue Feb 12 14:39:08 2019 +0530 HDDS-1081. CLOSING state containers should not be added to pipeline on SCM start. Contributed by Lokesh Jain. --- .../java/org/apache/hadoop/hdds/scm/container/SCMContainerManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 b7848bd..93abdcc 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 @@ -112,7 +112,7 @@ public class SCMContainerManager implements ContainerManager { ContainerInfoProto.PARSER.parseFrom(entry.getValue())); Preconditions.checkNotNull(container); containerStateManager.loadContainer(container); - if (container.isOpen()) { + if (container.getState() == LifeCycleState.OPEN) { pipelineManager.addContainerToPipeline(container.getPipelineID(), ContainerID.valueof(container.getContainerID())); } --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org