This is an automated email from the ASF dual-hosted git repository.
nanda pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new 0d6231c2b3 HDDS-12801. SCM should remove pipeline before DN. (#8261)
0d6231c2b3 is described below
commit 0d6231c2b371bf57e3fe59818cc81d256fb3305b
Author: Aryan Gupta <[email protected]>
AuthorDate: Fri Apr 11 13:22:42 2025 +0530
HDDS-12801. SCM should remove pipeline before DN. (#8261)
---
.../java/org/apache/hadoop/hdds/scm/pipeline/PipelineManagerImpl.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineManagerImpl.java
b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineManagerImpl.java
index fc8bb5432b..4ef1676618 100644
---
a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineManagerImpl.java
+++
b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineManagerImpl.java
@@ -446,7 +446,7 @@ public void openPipeline(PipelineID pipelineId)
*/
protected void removePipeline(Pipeline pipeline)
throws IOException {
- pipelineFactory.close(pipeline.getType(), pipeline);
+ // Removing the pipeline from SCM.
HddsProtos.PipelineID pipelineID = pipeline.getId().getProtobuf();
acquireWriteLock();
try {
@@ -457,6 +457,8 @@ protected void removePipeline(Pipeline pipeline)
} finally {
releaseWriteLock();
}
+ // Firing pipeline close command to datanode.
+ pipelineFactory.close(pipeline.getType(), pipeline);
LOG.info("Pipeline {} removed.", pipeline);
metrics.incNumPipelineDestroyed();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
