diff --git a/src/main/java/io/lettuce/core/cluster/RedisAdvancedClusterAsyncCommandsImpl.java b/src/main/java/io/lettuce/core/cluster/RedisAdvancedClusterAsyncCommandsImpl.java index ca07e8b662..cd034ea52b 100644 --- a/src/main/java/io/lettuce/core/cluster/RedisAdvancedClusterAsyncCommandsImpl.java +++ b/src/main/java/io/lettuce/core/cluster/RedisAdvancedClusterAsyncCommandsImpl.java @@ -415,7 +415,7 @@ public RedisFuture scriptFlush() { @Override public RedisFuture scriptKill() { - Map> executions = executeOnNodes(RedisScriptingAsyncCommands::scriptFlush, + Map> executions = executeOnNodes(RedisScriptingAsyncCommands::scriptKill, redisClusterNode -> true); return MultiNodeExecution.alwaysOkOfAsync(executions); }