diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java index 0be2b6de6eff..23be4138b603 100644 --- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java +++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java @@ -1005,12 +1005,15 @@ private void removeStateMachineDataIfNeeded(long index) { try { RaftServer.Division division = ratisServer.getServer().getDivision(getGroupId()); if (division.getInfo().isLeader()) { - long minIndex = Arrays.stream(division.getInfo() - .getFollowerNextIndices()).min().getAsLong(); - LOG.debug("Removing data corresponding to log index {} min index {} " - + "from cache", index, minIndex); - removeCacheDataUpTo(Math.min(minIndex, index)); + Arrays.stream(division.getInfo() + .getFollowerNextIndices()).min().ifPresent(minIndex -> { + removeCacheDataUpTo(Math.min(minIndex, index)); + LOG.debug("Removing data corresponding to log index {} min index {} " + + "from cache", index, minIndex); + }); } + } catch (RuntimeException e) { + throw e; } catch (Exception e) { throw new RuntimeException(e); }