diff --git a/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonClusterConnection.java b/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonClusterConnection.java index a5aa5e9a3..01273d952 100644 --- a/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonClusterConnection.java +++ b/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonClusterConnection.java @@ -454,7 +454,7 @@ public class RedissonClusterConnection extends RedissonConnection implements Red es.writeAsync(key, LongCodec.INSTANCE, RedisCommands.DEL, key); } BatchResult b = (BatchResult) es.execute(); - return b.getResponses().stream().collect(Collectors.summarizingLong(v -> v)).getSum(); + return b.getResponses().stream().mapToLong(v -> v).sum(); } @Override