From 2662e20580175c0824cbeb480edb05ffc00858e5 Mon Sep 17 00:00:00 2001 From: Nanda kumar Date: Tue, 6 Aug 2019 14:36:04 +0530 Subject: [PATCH] HDDS-1905. PipelineActionHandler is not closing the pipeline when close action is received. (#1227) --- .../apache/hadoop/hdds/scm/pipeline/PipelineActionHandler.java | 1 + 1 file changed, 1 insertion(+) diff --git a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineActionHandler.java b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineActionHandler.java index 34e974a0e1d..8d040f1df3f 100644 --- a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineActionHandler.java +++ b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineActionHandler.java @@ -61,6 +61,7 @@ public class PipelineActionHandler "Reason : {}", action.getAction(), pipeline, report.getDatanodeDetails(), action.getClosePipeline().getDetailedReason()); + pipelineManager.finalizeAndDestroyPipeline(pipeline, true); } catch (IOException ioe) { LOG.error("Could not execute pipeline action={} pipeline={} {}", action, pipelineID, ioe);