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 5cdd94b1f196..4ca569f3656a 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 @@ -2915,6 +2915,10 @@ public String getRatisRoles() { if (isRatisEnabled) { try { leaderId = omRatisServer.getLeader(); + if (leaderId == null) { + LOG.error("No leader found"); + return "Exception: Not a leader"; + } serviceList = getServiceList(); } catch (IOException e) { LOG.error("IO-Exception Occurred", e); diff --git a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/ratis/OzoneManagerRatisServer.java b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/ratis/OzoneManagerRatisServer.java index 9ab6ecdad272..bd8dcf9b7ee8 100644 --- a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/ratis/OzoneManagerRatisServer.java +++ b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/ratis/OzoneManagerRatisServer.java @@ -736,13 +736,15 @@ private static Map getOMHAConfigs( public RaftPeer getLeader() { try { RaftServer.Division division = server.getDivision(raftGroupId); - if (division.getInfo().isLeader()) { - return division.getPeer(); - } else { - ByteString leaderId = division.getInfo().getRoleInfoProto() - .getFollowerInfo().getLeaderInfo().getId().getId(); - return leaderId.isEmpty() ? null : - division.getRaftConf().getPeer(RaftPeerId.valueOf(leaderId)); + if (division != null) { + if (division.getInfo().isLeader()) { + return division.getPeer(); + } else { + ByteString leaderId = division.getInfo().getRoleInfoProto() + .getFollowerInfo().getLeaderInfo().getId().getId(); + return leaderId.isEmpty() ? null : + division.getRaftConf().getPeer(RaftPeerId.valueOf(leaderId)); + } } } catch (IOException e) { // In this case we return not a leader.