diff --git a/raft/log.go b/raft/log.go index 351c379ed..a6c851d6e 100644 --- a/raft/log.go +++ b/raft/log.go @@ -271,8 +271,8 @@ func (l *raftLog) maybeCommit(maxIndex, term uint64) bool { func (l *raftLog) restore(s pb.Snapshot) { l.committed = s.Metadata.Index - l.unstable.offset = l.committed - l.unstable.entries = []pb.Entry{{Index: s.Metadata.Index, Term: s.Metadata.Term}} + l.unstable.offset = l.committed + 1 + l.unstable.entries = nil l.unstable.snapshot = &s }