_actually_ uniq the endpoints. derp.

therealadam · Sep 7, 2010 · 17b5aa5 · 17b5aa5
1 parent aff0a9c
commit 17b5aa5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/cassandra/0.7/cassandra.rb b/lib/cassandra/0.7/cassandra.rb
@@ -39,7 +39,7 @@ def cluster_name
   end
 
   def ring
-    client.describe_ring(@keyspace).uniq
+    client.describe_ring(@keyspace)
   end
 
   def partitioner
@@ -154,7 +154,7 @@ def check_keyspace(ks = @keyspace)
 
   def all_nodes
     if @auto_discover_nodes && !@keyspace.eql?("system")
-      ips = (new_client.describe_ring(@keyspace).map {|range| range.endpoints}).flatten
+      ips = (new_client.describe_ring(@keyspace).map {|range| range.endpoints}).flatten.uniq
       port = @servers.first.split(':').last
       ips.map{|ip| "#{ip}:#{port}" }
     else