From 0cf37d586ef7b3fb0554319bd57fd6f28b9d96b5 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Tue, 11 Aug 2020 10:45:59 +0300 Subject: [PATCH] refactoring --- .../java/org/redisson/cluster/ClusterConnectionManager.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java b/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java index 5e1ec4c1a..effc95cc8 100644 --- a/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java +++ b/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java @@ -121,6 +121,10 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager { failedMasters.add(partition.getMasterAddress().toString()); continue; } + if (partition.getMasterAddress() == null) { + throw new IllegalStateException("Master node: " + partition.getNodeId() + " doesn't have address."); + } + RFuture masterFuture = addMasterEntry(partition, cfg); masterFutures.add(masterFuture); }