Fix leak connection when discovering cluster nodes

redis · Dec 18, 2014 · e5b6af2 · e5b6af2
1 parent d7f6091
commit e5b6af2
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/src/main/java/redis/clients/jedis/JedisClusterConnectionHandler.java b/src/main/java/redis/clients/jedis/JedisClusterConnectionHandler.java
@@ -45,11 +45,8 @@ public void assignSlotToNode(int slot, HostAndPort targetNode) {
 
   private void initializeSlotsCache(Set<HostAndPort> startNodes, GenericObjectPoolConfig poolConfig) {
     for (HostAndPort hostAndPort : startNodes) {
-      JedisPool jp = new JedisPool(poolConfig, hostAndPort.getHost(), hostAndPort.getPort());
-
-      Jedis jedis = null;
+      Jedis jedis = new Jedis(hostAndPort.getHost(), hostAndPort.getPort());
       try {
-        jedis = jp.getResource();
         cache.discoverClusterNodesAndSlots(jedis);
         break;
       } catch (JedisConnectionException e) {