Repository: incubator-ratis Updated Branches: refs/heads/master f9785690a -> 7255747a2
RATIS-404. Deadlock in ratis between appendEntries and RaftLogWorker. Project: http://git-wip-us.apache.org/repos/asf/incubator-ratis/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ratis/commit/7255747a Tree: http://git-wip-us.apache.org/repos/asf/incubator-ratis/tree/7255747a Diff: http://git-wip-us.apache.org/repos/asf/incubator-ratis/diff/7255747a Branch: refs/heads/master Commit: 7255747a2b6b423a47ee82dd80728e52c7a05d6b Parents: f978569 Author: Tsz Wo Nicholas Sze <[email protected]> Authored: Fri Nov 9 13:01:55 2018 -0800 Committer: Tsz Wo Nicholas Sze <[email protected]> Committed: Fri Nov 9 13:01:55 2018 -0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/ratis/server/impl/RaftServerImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ratis/blob/7255747a/ratis-server/src/main/java/org/apache/ratis/server/impl/RaftServerImpl.java ---------------------------------------------------------------------- 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 09e4550..48a21ee 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 @@ -920,7 +920,7 @@ public class RaftServerImpl implements RaftServerProtocol, RaftServerAsynchronou if (!isHeartbeat) { CodeInjectionForTesting.execute(RaftLog.LOG_SYNC, getId(), null); } - return JavaUtils.allOf(futures).thenApply(v -> { + return JavaUtils.allOf(futures).thenApplyAsync(v -> { final AppendEntriesReplyProto reply; synchronized(this) { if (lifeCycle.getCurrentState() == RUNNING && isFollower()
