This is an automated email from the ASF dual-hosted git repository.
weichiu 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 af22a5c3a43 HDDS-13621. NPE in OzoneManagerRatisServer.checkRetryCache
(#9711)
af22a5c3a43 is described below
commit af22a5c3a435f771c17307d325d7e80eae7361ec
Author: Sergey Soldatov <[email protected]>
AuthorDate: Wed Feb 4 22:12:30 2026 -0800
HDDS-13621. NPE in OzoneManagerRatisServer.checkRetryCache (#9711)
---
.../org/apache/hadoop/ozone/om/ratis/OzoneManagerRatisServer.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
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 99cddaec748..bccf9e0900a 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) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
