diff --git a/raft/raft.go b/raft/raft.go index 33507632d..3f536449e 100644 --- a/raft/raft.go +++ b/raft/raft.go @@ -411,6 +411,7 @@ func stepFollower(sm *stateMachine, m Message) bool { m.To = sm.lead.Get() sm.send(m) case msgApp: + sm.lead.Set(m.From) sm.handleAppendEntries(m) case msgSnap: sm.handleSnapshot(m)