From c507014c262fc12157e43bc5c00d7fb522b660ad Mon Sep 17 00:00:00 2001 From: Nikita Date: Fri, 10 Jun 2016 18:21:11 +0300 Subject: [PATCH] Fixed cluster state managing with redis masters only. #491 --- .../java/org/redisson/cluster/ClusterConnectionManager.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/org/redisson/cluster/ClusterConnectionManager.java b/src/main/java/org/redisson/cluster/ClusterConnectionManager.java index 0fd5e56b8..9741e3f41 100644 --- a/src/main/java/org/redisson/cluster/ClusterConnectionManager.java +++ b/src/main/java/org/redisson/cluster/ClusterConnectionManager.java @@ -226,9 +226,9 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager { e = new MasterSlaveEntry(partition.getSlotRanges(), ClusterConnectionManager.this, config); + List> fs = e.initSlaveBalancer(partition.getFailedSlaveAddresses()); + futures.addAll(fs); if (!partition.getSlaveAddresses().isEmpty()) { - List> fs = e.initSlaveBalancer(partition.getFailedSlaveAddresses()); - futures.addAll(fs); log.info("slaves: {} added for slot ranges: {}", partition.getSlaveAddresses(), partition.getSlotRanges()); if (!partition.getFailedSlaveAddresses().isEmpty()) { log.warn("slaves: {} is down for slot ranges: {}", partition.getFailedSlaveAddresses(), partition.getSlotRanges()); @@ -403,7 +403,7 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager { currentPart.addSlaveAddress(uri); entry.slaveUp(uri.getHost(), uri.getPort(), FreezeReason.MANAGER); - log.info("slave {} added for slot ranges: {}", uri, currentPart.getSlotRanges()); + log.info("slave: {} added for slot ranges: {}", uri, currentPart.getSlotRanges()); } }); }