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;