Fixed - cluster partition without address causes NPE. #3541

4 years ago · c8a9b8cd02
parent 0b593380ab
commit c8a9b8cd02
1 changed files with 3 additions and 1 deletions
--- a/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java
+++ b/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java
@ -767,7 +767,9 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager {
    private Collection<ClusterPartition> parsePartitions(List<ClusterNodeInfo> nodes) {
        Map<String, ClusterPartition> partitions = new HashMap<>();
        for (ClusterNodeInfo clusterNodeInfo : nodes) {
-            if (clusterNodeInfo.containsFlag(Flag.NOADDR) || clusterNodeInfo.containsFlag(Flag.HANDSHAKE)) {
+            if (clusterNodeInfo.containsFlag(Flag.NOADDR)
+                    || clusterNodeInfo.containsFlag(Flag.HANDSHAKE)
+                        || clusterNodeInfo.getAddress() == null) {
                // skip it
                continue;
            }