Merge pull request #787 from layerhq/fix-handshake-node-bug

Skip cluster nodes with the "handshake" flag
pull/794/head
Nikita Koksharov 8 years ago committed by GitHub
commit 06cf98016f

@ -671,7 +671,7 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager {
private Collection<ClusterPartition> parsePartitions(List<ClusterNodeInfo> nodes) { private Collection<ClusterPartition> parsePartitions(List<ClusterNodeInfo> nodes) {
Map<String, ClusterPartition> partitions = new HashMap<String, ClusterPartition>(); Map<String, ClusterPartition> partitions = new HashMap<String, ClusterPartition>();
for (ClusterNodeInfo clusterNodeInfo : nodes) { for (ClusterNodeInfo clusterNodeInfo : nodes) {
if (clusterNodeInfo.containsFlag(Flag.NOADDR)) { if (clusterNodeInfo.containsFlag(Flag.NOADDR) || clusterNodeInfo.containsFlag(Flag.HANDSHAKE)) {
// skip it // skip it
continue; continue;
} }

Loading…
Cancel
Save