Index: RoundRobinPolicy.java =================================================================== --- RoundRobinPolicy.java (revision 56873) +++ RoundRobinPolicy.java (working copy) @@ -271,7 +271,10 @@ private ClusterInstanceInfo makeClusterInstanceInfo(String str, int weight) { - String[] host_port = str.split(":"); + String[] host_port = new String[2]; + int i = str.lastIndexOf(':'); + host_port[0] = str.substring(0,i); + host_port[1] = str.substring(i+1); String server_identifier = ""; //for bootstrapping, can be "" String type = CLEAR_TEXT; //will be clear_text for bootstrapping SocketInfo socketInfo = new SocketInfo(