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 a89ba1a4c4 HDDS-7584. Addition of new OM node expels itself from the
Ratis ring after restart (#4074)
a89ba1a4c4 is described below
commit a89ba1a4c485ddff7bf213efd871ee8807520e8a
Author: Aryan Gupta <[email protected]>
AuthorDate: Fri Dec 23 12:50:10 2022 +0530
HDDS-7584. Addition of new OM node expels itself from the Ratis ring after
restart (#4074)
---
.../src/main/java/org/apache/hadoop/ozone/om/OzoneManager.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OzoneManager.java
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OzoneManager.java
index ed3dc058b1..f59dfebde6 100644
---
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OzoneManager.java
+++
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OzoneManager.java
@@ -1776,10 +1776,10 @@ public final class OzoneManager extends
ServiceRuntimeInfoImpl
for (String omNodeId : decommissionedOMs) {
if (isCurrentNode(omNodeId)) {
// Decommissioning Node should not receive the configuration change
- // request. Shut it down.
- String errorMsg = "Shutting down as OM has been decommissioned.";
- LOG.error("Fatal Error: {}", errorMsg);
- exitManager.forceExit(1, errorMsg, LOG);
+ // request. It may receive the request if the newly added node id or
+ // the decommissioned node id is same.
+ LOG.warn("New OM node Id: {} is same as decommissioned earlier",
+ omNodeId);
} else {
// Remove decommissioned node from peer list (which internally
// removed from Ratis peer list too)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
