Fixed - "Can't add slave" exceptions after fail over in cluster mode. #4278

3 years ago · 459762d964
parent aa63d50f2d
commit 459762d964
1 changed files with 4 additions and 2 deletions
--- a/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java
+++ b/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java
@ -520,8 +520,10 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager {
            }
        }

-        Set<RedisURI> addedSlaves = new HashSet<>(newPart.getSlaveAddresses());
-        addedSlaves.removeAll(currentPart.getSlaveAddresses());
+        Set<RedisURI> addedSlaves = newPart.getSlaveAddresses().stream()
+                                                                .filter(uri -> !currentPart.getSlaveAddresses().contains(uri)
+                                                                                && !newPart.getFailedSlaveAddresses().contains(uri))
+                                                                .collect(Collectors.toSet());
        for (RedisURI uri : addedSlaves) {
            ClientConnectionsEntry slaveEntry = entry.getEntry(uri);
            if (slaveEntry != null) {