Improvement - optimization of ClusterConnectionManager.checkSlaveNodesChange() and ClusterConnectionManager.checkMasterNodesChange() methods. #3886

pull/3930/head
Nikita Koksharov 3 years ago
parent 59e6a271bf
commit 9fc12cae2e

@ -871,7 +871,7 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager {
}
private Map<RedisURI, ClusterPartition> getLastPartitonsByURI() {
return lastPartitions.values().stream().collect(Collectors.toMap(p -> p.getMasterAddress(), p -> p));
return lastPartitions.values().stream().collect(Collectors.toMap(p -> p.getMasterAddress(), p -> p, (e1, e2) -> e1));
}
private Set<ClusterPartition> getLastPartitions() {

Loading…
Cancel
Save