(ratis) branch master updated: RATIS-2314. Fix that SegmentedRaftLogWorker may append entry by itself. (#1274)

[szetszwo]

This is an automated email from the ASF dual-hosted git repository.

szetszwo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ratis.git


The following commit(s) were added to refs/heads/master by this push:
     new b73c44caa RATIS-2314. Fix that SegmentedRaftLogWorker may append entry 
by itself. (#1274)
b73c44caa is described below

commit b73c44caa6e0150d57cd0e6694b89430555e27bd
Author: Jiang Tian <jt2594...@163.com>
AuthorDate: Thu Jul 3 05:33:47 2025 +0800

    RATIS-2314. Fix that SegmentedRaftLogWorker may append entry by itself. 
(#1274)
---
 .../src/main/java/org/apache/ratis/server/impl/RaftServerImpl.java   | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

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
index 7f3ed9831..e5d9bfeca 100644
--- 
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
@@ -1639,8 +1639,9 @@ class RaftServerImpl implements RaftServer.Division,
       return appendLogFuture.get();
     }
 
-    return appendLogFuture.updateAndGet(f -> f.thenCompose(
-            ignored -> JavaUtils.allOf(state.getLog().append(entries))))
+
+    return appendLogFuture.updateAndGet(f -> f.thenComposeAsync(
+            ignored -> JavaUtils.allOf(state.getLog().append(entries)), 
serverExecutor))
         .whenComplete((v, e) -> 
appendLogTermIndices.removeExisting(entriesTermIndices));
   }