From b3ed8361ecc78be9c5adbfd551c2b4c6d54e839a Mon Sep 17 00:00:00 2001
From: Nikita Koksharov <nkoksharov@redisson.pro>
Date: Fri, 1 Mar 2024 10:57:45 +0300
Subject: [PATCH] error logs fixed

---
 .../java/org/redisson/cluster/ClusterConnectionManager.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java b/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java
index a1426beed..6673effed 100644
--- a/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java
+++ b/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java
@@ -504,7 +504,7 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager {
             // should be invoked first in order to remove stale failedSlaveAddresses
             CompletableFuture<Set<RedisURI>> addedSlavesFuture = addRemoveSlaves(entry, currentPart, newPart);
             CompletableFuture<Void> f = addedSlavesFuture.thenCompose(addedSlaves -> {
-                // Do some slaves have changed state from failed to alive?
+                // Have some slaves changed state from failed to alive?
                 return upDownSlaves(entry, currentPart, newPart, addedSlaves);
             });
             futures.add(f);
@@ -512,7 +512,7 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager {
         return CompletableFuture.allOf(futures.toArray(new CompletableFuture[0]))
                                     .exceptionally(e -> {
                                         if (e != null) {
-                                            log.error(e.getMessage(), e);
+                                            log.error("Unable to add/remove slave nodes", e);
                                         }
                                         return null;
                                     });
@@ -656,7 +656,7 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager {
         return CompletableFuture.allOf(futures.toArray(new CompletableFuture[0]))
                                     .exceptionally(e -> {
                                         if (e != null) {
-                                            log.error(e.getMessage(), e);
+                                            log.error("Unable to add/change master node", e);
                                         }
                                         return null;
                                     });