diff --git a/migrate/snapshot.go b/migrate/snapshot.go index 7dfe270a6..8a457fac9 100644 --- a/migrate/snapshot.go +++ b/migrate/snapshot.go @@ -171,15 +171,17 @@ func (s *Snapshot4) Snapshot5() *raftpb.Snapshot { log.Fatal("Couldn't re-marshal new snapshot") } + nodes := s.GetNodesFromStore() + nodeList := make([]uint64, 0) + for _, v := range nodes { + nodeList = append(nodeList, v) + } + snap5 := raftpb.Snapshot{ Data: newState, Index: s.LastIndex, Term: s.LastTerm, - Nodes: make([]uint64, len(s.Peers)), - } - - for i, p := range s.Peers { - snap5.Nodes[i] = hashName(p.Name) + Nodes: nodeList, } return &snap5