diff --git a/src/raft.rs b/src/raft.rs index 60b92a6c..6020f6cd 100644 --- a/src/raft.rs +++ b/src/raft.rs @@ -1882,6 +1882,8 @@ impl Raft { if pr.matched < self.r.raft_log.last_index() || pr.pending_request_snapshot != INVALID_INDEX { self.r.send_append(m.from, pr, &mut self.msgs); + } else { + pr.become_replicate(); } if self.read_only.option != ReadOnlyOption::Safe || m.context.is_empty() {