diff --git a/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java b/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java
index 9ce7274ad..950247641 100644
--- a/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java
+++ b/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java
@@ -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()))