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 5fb3872d8819..65cd28836ac2 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 @@ -2223,7 +2223,6 @@ public boolean stop() { } if (omRatisServer != null) { omRatisServer.stop(); - omRatisServer = null; OMHAMetrics.unRegister(); } isOmRpcServerRunning = false; @@ -2260,6 +2259,7 @@ public boolean stop() { if (omhaMetrics != null) { OMHAMetrics.unRegister(); } + omRatisServer = null; return true; } catch (Exception e) { LOG.error("OzoneManager stop failed.", e); @@ -3032,6 +3032,9 @@ public String getRatisRoles() { int port = omNodeDetails.getRatisPort(); RaftPeer leaderId; if (isRatisEnabled) { + if (null == omRatisServer) { + return "Server is shutting down"; + } try { leaderId = omRatisServer.getLeader(); if (leaderId == null) {