writeFuture should be canceled on last attempt.

redisson/src/main/java/org/redisson/command/CommandAsyncService.java

@@ -538,6 +538,13 @@ public class CommandAsyncService implements CommandAsyncExecutor {
                     if (details.getConnectionFuture().isSuccess()) {
                         if (details.getWriteFuture() == null || !details.getWriteFuture().isDone()) {
                             if (details.getAttempt() == connectionManager.getConfig().getRetryAttempts()) {
+                                if (details.getWriteFuture().cancel(false)) {
+                                    free(details);
+                                    if (details.getException() == null) {
+                                        details.setException(new RedisTimeoutException("Unable to send command: " + command + " with params: " + LogHelper.toString(details.getParams() + " after " + connectionManager.getConfig().getRetryAttempts() + " retry attempts")));
+                                    }
+                                    details.getAttemptPromise().tryFailure(details.getException());
+                                }
                                 return;
                             }
                             details.incAttempt();

redisson/src/main/java/org/redisson/command/CommandBatchService.java

@@ -45,6 +45,7 @@ import org.redisson.connection.ConnectionManager;
 import org.redisson.connection.MasterSlaveEntry;
 import org.redisson.connection.NodeSource;
 import org.redisson.connection.NodeSource.Redirect;
+import org.redisson.misc.LogHelper;
 import org.redisson.misc.RPromise;
 import org.redisson.misc.RedissonObjectFactory;
 
@@ -296,6 +297,13 @@ public class CommandBatchService extends CommandAsyncService {
                     if (connectionFuture.isSuccess()) {
                         if (details.getWriteFuture() == null || !details.getWriteFuture().isDone()) {
                             if (details.getAttempt() == attempts) {
+                                if (details.getWriteFuture().cancel(false)) {
+                                    free(entry);
+                                    if (details.getException() == null) {
+                                        details.setException(new RedisTimeoutException("Unable to send batch after " + connectionManager.getConfig().getRetryAttempts() + " retry attempts"));
+                                    }
+                                    details.getAttemptPromise().tryFailure(details.getException());
+                                }
                                 return;
                             }
                             details.incAttempt();