Browse Source

fix(join_command): use RaftURL as peer address

Yicheng Qin 11 years ago
parent
commit
e0fbe27c99
1 changed files with 1 additions and 1 deletions
  1. 1 1
      server/join_command.go

+ 1 - 1
server/join_command.go

@@ -66,7 +66,7 @@ func (c *JoinCommandV1) Apply(context raft.Context) (interface{}, error) {
 	// Check if the join command adds an instance that collides with existing one on peer URL.
 	peerURLs := ps.registry.PeerURLs(ps.raftServer.Leader(), c.Name)
 	for _, peerURL := range peerURLs {
-		if peerURL == c.EtcdURL {
+		if peerURL == c.RaftURL {
 			log.Warnf("%v tries to join the cluster with existing URL %v", c.Name, c.EtcdURL)
 			return []byte{0}, etcdErr.NewError(etcdErr.EcodeExistingPeerAddr, c.EtcdURL, context.CommitIndex())
 		}