diff --git a/redisson/src/main/java/org/redisson/command/RedisExecutor.java b/redisson/src/main/java/org/redisson/command/RedisExecutor.java index 8520940ac..8f7e543a7 100644 --- a/redisson/src/main/java/org/redisson/command/RedisExecutor.java +++ b/redisson/src/main/java/org/redisson/command/RedisExecutor.java @@ -308,8 +308,8 @@ public class RedisExecutor { attempt++; if (log.isDebugEnabled()) { - log.debug("attempt {} for command {} and params {}", - attempt, command, LogHelper.toString(params)); + log.debug("attempt {} for command {} and params {} to {}", + attempt, command, LogHelper.toString(params), source); } mainPromiseListener = null; @@ -387,8 +387,8 @@ public class RedisExecutor { connectionManager.getServiceManager().newTimeout(t -> { attempt++; if (log.isDebugEnabled()) { - log.debug("attempt {} for command {} and params {}", - attempt, command, LogHelper.toString(params)); + log.debug("response timeout. new attempt {} for command {} and params {} node {}", + attempt, command, LogHelper.toString(params), source); } mainPromiseListener = null;