Preventing sending CLUSTER NODES to the same host

Signed-off-by: Sergey Peretyatko <sergey@peretyatko.com>
pull/3161/head
Sergey Peretyatko 4 years ago
parent 07f4e089bd
commit fe764d763b

@ -393,6 +393,9 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager {
partitionSlaves.removeAll(partition.getFailedSlaveAddresses());
slaves.addAll(partitionSlaves);
}
Collections.shuffle(nodes);
Collections.shuffle(slaves);
// master nodes first
nodes.addAll(slaves);

Loading…
Cancel
Save