diff --git a/cluster.go b/cluster.go
index bdfdb83..ab2c76f 100644
--- a/cluster.go
+++ b/cluster.go
@@ -1551,6 +1551,8 @@ func (c *ClusterClient) pubSub() *PubSub {
 
 			cn, err := node.Client.newConn()
 			if err != nil {
+				node = nil
+
 				return nil, err
 			}