diff --git a/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java b/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java index dcfc7b0e7..3e0880837 100644 --- a/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java +++ b/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java @@ -846,7 +846,7 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager { CompletableFuture> ipsFuture = serviceManager.resolveAll(clusterNodeInfo.getAddress()); CompletableFuture f = ipsFuture.thenAccept(addresses -> { - if (addresses.size() > 1 && clusterNodeInfo.containsFlag(Flag.MASTER)) { + if (addresses.size() > 1) { addresses.sort(Comparator.comparing(RedisURI::getHost)); Collections.shuffle(addresses, new Random(serviceManager.getId().hashCode())); }