Adding a node only if it is not in the raft peer list

This commit is contained in:
Jitendra Bhurat 2019-03-15 11:36:41 -04:00
parent af38cd133d
commit 7eedfd2059
1 changed files with 1 additions and 1 deletions

View File

@ -754,7 +754,7 @@ func (pm *ProtocolManager) eventLoop() {
case raftpb.ConfChangeAddNode:
if pm.isRaftIdRemoved(raftId) {
log.Info("ignoring ConfChangeAddNode for permanently-removed peer", "raft id", raftId)
} else if raftId <= uint16(len(pm.bootstrapNodes)) {
} else if peer := pm.peers[raftId]; peer != nil && raftId <= uint16(len(pm.bootstrapNodes)) {
// See initial cluster logic in startRaft() for more information.
log.Info("ignoring expected ConfChangeAddNode for initial peer", "raft id", raftId)