fix nullpointer on getState()

SzyWilliam · May 29, 2024 · cd467d9 · cd467d9
1 parent 9c8b7b8
commit cd467d9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ratis-server/src/main/java/org/apache/ratis/server/impl/RaftServerImpl.java b/ratis-server/src/main/java/org/apache/ratis/server/impl/RaftServerImpl.java
@@ -1853,7 +1853,7 @@ CompletableFuture<Message> applyLogToStateMachine(ReferenceCountedObject<LogEntr
   void notifyTruncatedLogEntry(LogEntryProto logEntry) {
     if (logEntry.hasStateMachineLogEntry()) {
       getTransactionManager().remove(TermIndex.valueOf(logEntry));
-      getState().truncate(logEntry.getIndex());
+      Optional.ofNullable(getState()).ifPresent(s -> s.truncate(logEntry.getIndex()));
 
       final ClientInvocationId invocationId = ClientInvocationId.valueOf(logEntry.getStateMachineLogEntry());
       final CacheEntry cacheEntry = getRetryCache().getIfPresent(invocationId);