static test to avoid reinitialization

src/org/datanucleus/store/cassandra/CassandraConnectionInfo.java

@@ -31,11 +31,17 @@
 
 public class CassandraConnectionInfo {
 
-	private Map<String, Integer> ring_connections;
-	private String keyspace;
+	private static Map<String, Integer> ring_connections;
+	private static String keyspace;
 
+	private static boolean intialized = false;
+
 	public CassandraConnectionInfo(PersistenceConfiguration conf) {
 
+		if(intialized){
+			return;
+		}
+
 		ring_connections = new TreeMap<String, Integer>();
 
 		String url = conf.getStringProperty("datanucleus.ConnectionURL");
@@ -168,16 +174,19 @@ public CassandraConnectionInfo(PersistenceConfiguration conf) {
 						.describe_ring(keyspace);
 				for (TokenRange tr : ring) {
 					List<String> endpoints = tr.endpoints;
-					for (String enpoint : endpoints) {
-						ring_connections.put(enpoint, endpoint_port);
+					for (String endpoint : endpoints) {
+						if(!ring_connections.containsKey(endpoint)){
+							//System.out.println("New node connection->"+endpoint+":"+endpoint_port);
+							ring_connections.put(endpoint, endpoint_port);
+						}
 					}
 				}
 			} catch (TException e) {
 				throw new NucleusDataStoreException(e.getMessage(), e);
 			}
 
 		}
-
+		intialized = true;
 	}
 
 	public Map<String, Integer> getConnections() {