Fixed - Attempts to connect to the failed master after failover in cluster mode #4649

pull/4502/head
Nikita Koksharov 2 years ago
parent c60b275de7
commit 96da883f0f

@ -242,6 +242,10 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager {
entry.masterDown();
entry.shutdownAsync();
subscribeService.remove(entry);
RedisURI uri = new RedisURI(entry.getClient().getConfig().getAddress().getScheme(),
entry.getClient().getAddr().getAddress().getHostAddress(),
entry.getClient().getAddr().getPort());
disconnectNode(uri);
String slaves = entry.getAllEntries().stream()
.filter(e -> !e.getClient().getAddr().equals(entry.getClient().getAddr()))

Loading…
Cancel
Save