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 d461a01a5 RATIS-1895. IllegalStateException: Failed to 
updateIncreasingly for nextIndex. (#926)
d461a01a5 is described below

commit d461a01a53e7e130f0ec4143e75b316012137b62
Author: William Song <[email protected]>
AuthorDate: Tue Sep 26 00:47:37 2023 +0800

    RATIS-1895. IllegalStateException: Failed to updateIncreasingly for 
nextIndex. (#926)
---
 .../src/main/java/org/apache/ratis/grpc/server/GrpcLogAppender.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcLogAppender.java 
b/ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcLogAppender.java
index eb3195326..8bc616ad9 100644
--- a/ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcLogAppender.java
+++ b/ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcLogAppender.java
@@ -420,7 +420,7 @@ public class GrpcLogAppender extends LogAppenderBase {
           grpcServerMetrics.onRequestSuccess(getFollowerId().toString(), 
reply.getIsHearbeat());
           getLeaderState().onFollowerCommitIndex(getFollower(), 
reply.getFollowerCommit());
           if (getFollower().updateMatchIndex(reply.getMatchIndex())) {
-            getFollower().increaseNextIndex(reply.getMatchIndex() + 1);
+            getFollower().updateNextIndex(reply.getMatchIndex() + 1);
             getLeaderState().onFollowerSuccessAppendEntries(getFollower());
           }
           break;

Reply via email to