diff --git a/lib/aerospike/cluster/cluster.rb b/lib/aerospike/cluster/cluster.rb
index <HASH>..<HASH> 100644
--- a/lib/aerospike/cluster/cluster.rb
+++ b/lib/aerospike/cluster/cluster.rb
@@ -35,7 +35,7 @@ module Aerospike
       @cluster_nodes = []
       @partition_write_map = {}
       @node_index = Atomic.new(0)
-      @closed = Atomic.new(false)
+      @closed = Atomic.new(true)
       @mutex = Mutex.new
 
       # setup auth info for cluster
@@ -271,6 +271,8 @@ module Aerospike
         thr.kill if thr.alive?
       end
 
+      @closed.value = false if @cluster_nodes.length > 0
+
     end
 
     def set_partitions(part_map)
Fix cluster connection logic to correctly set the @closed value