This is an automated email from the ASF dual-hosted git repository.
runzhiwang pushed a commit to branch HDDS-2823
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/HDDS-2823 by this push:
new 572a7de HDDS-4533.Avoid rewriting pipeline information during
PipelineStateManagerV2Impl initialization (#1796)
572a7de is described below
commit 572a7ded076f7844db6641ab8729a9c27cfff352
Author: Rui Wang <[email protected]>
AuthorDate: Thu Jan 14 18:45:23 2021 -0800
HDDS-4533.Avoid rewriting pipeline information during
PipelineStateManagerV2Impl initialization (#1796)
---
.../apache/hadoop/hdds/scm/pipeline/PipelineStateManagerV2Impl.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineStateManagerV2Impl.java
b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineStateManagerV2Impl.java
index 8f5ebc4..c9fb002 100644
---
a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineStateManagerV2Impl.java
+++
b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineStateManagerV2Impl.java
@@ -78,7 +78,8 @@ public class PipelineStateManagerV2Impl implements
StateManager {
iterator = pipelineStore.iterator();
while (iterator.hasNext()) {
Pipeline pipeline = iterator.next().getValue();
- addPipeline(pipeline.getProtobufMessage());
+ pipelineStateMap.addPipeline(pipeline);
+ nodeManager.addPipeline(pipeline);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
