Переглянути джерело

Merge pull request #508 from balboah/discover_rcp_address

Set rpc_address for discovered hosts
Chris Bannister 10 роки тому
батько
коміт
a13e827ba9
2 змінених файлів з 2 додано та 1 видалено
  1. 1 0
      AUTHORS
  2. 1 1
      host_source.go

+ 1 - 0
AUTHORS

@@ -57,3 +57,4 @@ Adrien Bustany <adrien@bustany.org>
 Andrey Smirnov <smirnov.andrey@gmail.com>
 Adam Weiner <adamsweiner@gmail.com>
 Daniel Cannon <daniel@danielcannon.co.uk>
+Johnny Bergström <johnny@joonix.se>

+ 1 - 1
host_source.go

@@ -98,7 +98,7 @@ func (r *ringDescriber) GetHosts() (hosts []HostInfo, partitioner string, err er
 
 	hosts = []HostInfo{localHost}
 
-	iter := r.session.control.query("SELECT peer, data_center, rack, host_id, tokens FROM system.peers")
+	iter := r.session.control.query("SELECT rpc_address, data_center, rack, host_id, tokens FROM system.peers")
 	if iter == nil {
 		return r.prevHosts, r.prevPartitioner, nil
 	}