command future cancel state checking fixed

src/main/java/org/redisson/CommandBatchExecutorService.java

@@ -16,7 +16,6 @@
 package org.redisson;
 
 import java.util.ArrayList;
-import java.util.Arrays;
 import java.util.Collections;
 import java.util.List;
 import java.util.Queue;
@@ -224,7 +223,12 @@ public class CommandBatchExecutorService extends CommandExecutorService {
                     connectionManager.getShutdownLatch().release();
                 }
 
-                if (attemptPromise.isDone() || mainPromise.isCancelled()) {
+                if (attemptPromise.isDone()) {
+                    return;
+                }
+
+                if (mainPromise.isCancelled()) {
+                    attemptPromise.cancel(false);
                     return;
                 }
 

src/main/java/org/redisson/CommandExecutorService.java

@@ -440,7 +440,12 @@ public class CommandExecutorService implements CommandExecutor {
                     connectionManager.getShutdownLatch().release();
                 }
 
-                if (attemptPromise.isDone() || mainPromise.isCancelled()) {
+                if (attemptPromise.isDone()) {
+                    return;
+                }
+
+                if (mainPromise.isCancelled()) {
+                    attemptPromise.cancel(false);
                     return;
                 }
 
@@ -457,7 +462,7 @@ public class CommandExecutorService implements CommandExecutor {
             }
         };
 
-        ex.set(new RedisTimeoutException("Command execution timeout for command: " + command + " with params " + Arrays.toString(params)));
+        ex.set(new RedisTimeoutException("Command execution timeout for command: " + command + " with params " + Arrays.toString(params) + " attempt " + attempt));
         final Timeout timeout = connectionManager.newTimeout(retryTimerTask, connectionManager.getConfig().getTimeout(), TimeUnit.MILLISECONDS);
 
         connectionFuture.addListener(new FutureListener<RedisConnection>() {