diff --git a/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java b/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java index 6cd484297..bf67cb257 100644 --- a/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java +++ b/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java @@ -871,7 +871,7 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager { } private Map 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 getLastPartitions() {