diff --git a/src/main/java/org/redisson/connection/RedisClientEntry.java b/src/main/java/org/redisson/connection/RedisClientEntry.java index 112ab541d..289d9dae0 100644 --- a/src/main/java/org/redisson/connection/RedisClientEntry.java +++ b/src/main/java/org/redisson/connection/RedisClientEntry.java @@ -94,13 +94,16 @@ public class RedisClientEntry implements ClusterNode { @Override public Map info() { - RedisConnection c = connect(); + RedisConnection c = null; try { + c = connect(); return c.sync(RedisCommands.CLUSTER_INFO); } catch (Exception e) { return null; } finally { - c.closeAsync(); + if (c != null) { + c.closeAsync(); + } } }