You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ozone.apache.org by sh...@apache.org on 2021/06/09 07:56:24 UTC
[ozone] branch master updated: HDDS-5284. [SCM-HA] SCM start failed
with PipelineNotFoundException. (#2295)
This is an automated email from the ASF dual-hosted git repository.
shashikant 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 fe9ca6e HDDS-5284. [SCM-HA] SCM start failed with PipelineNotFoundException. (#2295)
fe9ca6e is described below
commit fe9ca6e55d3d639aafbaab559dddb464438b4e0b
Author: bshashikant <sh...@apache.org>
AuthorDate: Wed Jun 9 13:26:00 2021 +0530
HDDS-5284. [SCM-HA] SCM start failed with PipelineNotFoundException. (#2295)
---
.../apache/hadoop/hdds/scm/pipeline/PipelineStateManagerV2Impl.java | 6 ++++++
1 file changed, 6 insertions(+)
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 8473b5a..50d1044 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
@@ -209,6 +209,9 @@ public class PipelineStateManagerV2Impl implements StateManager {
Pipeline pipeline = pipelineStateMap.removePipeline(pipelineID);
nodeManager.removePipeline(pipeline);
LOG.info("Pipeline {} removed.", pipeline);
+ } catch (PipelineNotFoundException pnfe) {
+ LOG.warn("Pipeline {} is not found in the pipeline Map. Pipeline"
+ + " may have been deleted already.", pipelineIDProto.getId());
} finally {
lock.writeLock().unlock();
}
@@ -256,6 +259,9 @@ public class PipelineStateManagerV2Impl implements StateManager {
transactionBuffer
.addToBuffer(pipelineStore, pipelineID, getPipeline(pipelineID));
}
+ } catch (PipelineNotFoundException pnfe) {
+ LOG.warn("Pipeline {} is not found in the pipeline Map. Pipeline"
+ + " may have been deleted already.", pipelineID);
} catch (IOException ex) {
LOG.warn("Pipeline {} state update failed", pipelineID);
// revert back to old state in memory
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@ozone.apache.org
For additional commands, e-mail: commits-help@ozone.apache.org