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 aa2e42d72da3..ab935aef16dc 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 @@ -542,7 +542,11 @@ public OMResponse checkRetryCache() throws ServiceException { } //cache hit try { - return getOMResponse(cacheEntry.getReplyFuture().get()); + RaftClientReply reply = cacheEntry.getReplyFuture().get(); + if (!reply.isSuccess()) { + return null; + } + return getOMResponse(reply); } catch (ExecutionException ex) { throw new ServiceException(ex.getMessage(), ex); } catch (InterruptedException ex) {