diff --git a/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java b/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java index c0e68a94c..21a1267cc 100644 --- a/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java +++ b/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java @@ -67,12 +67,11 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager { private ClusterServersConfig cfg; - private final long seed; + private final long seed = ThreadLocalRandom.current().nextLong(); public ClusterConnectionManager(ClusterServersConfig cfg, ServiceManager serviceManager) { super(cfg, serviceManager); this.serviceManager.setNatMapper(cfg.getNatMapper()); - this.seed = ThreadLocalRandom.current().nextLong(); } @Override @@ -343,9 +342,11 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager { CompletableFuture fs = entry.initSlaveBalancer(partition.getFailedSlaveAddresses(), r -> configEndpointHostName); return fs.thenAccept(r -> { if (!partition.getSlaveAddresses().isEmpty()) { - log.info("slaves: {} added for slot ranges: {}", partition.getSlaveAddresses(), partition.getSlotRanges()); + log.info("slaves: {} added for master: {} slot ranges: {}", + partition.getSlaveAddresses(), partition.getMasterAddress(), partition.getSlotRanges()); if (!partition.getFailedSlaveAddresses().isEmpty()) { - log.warn("slaves: {} are down for slot ranges: {}", partition.getFailedSlaveAddresses(), partition.getSlotRanges()); + log.warn("slaves: {} down for master: {} slot ranges: {}", + partition.getFailedSlaveAddresses(), partition.getMasterAddress(), partition.getSlotRanges()); } }