Fixed - NPE is thrown by RedisExecutor.handleError() method. #5641

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

@@ -614,6 +614,10 @@ public class RedisExecutor<V, R> {
 
     protected void handleError(CompletableFuture<RedisConnection> connectionFuture, Throwable cause) {
         mainPromise.completeExceptionally(cause);
+        if (connectionFuture == null) {
+            return;
+        }
+
         RedisClient client = connectionFuture.join().getRedisClient();
         client.getConfig().getFailedNodeDetector().onCommandFailed(cause);
         if (client.getConfig().getFailedNodeDetector().isNodeFailed()) {

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

@@ -129,6 +129,10 @@ public class RedisQueuedBatchExecutor<V, R> extends BaseRedisBatchExecutor<V, R>
             sentPromise.completeExceptionally(cause);
             mainPromise.completeExceptionally(cause);
             if (executed.compareAndSet(false, true)) {
+                if (connectionFuture == null) {
+                    return;
+                }
+
                 RedisConnection c = getNow(connectionFuture);
                 if (c != null) {
                     c.forceFastReconnectAsync().whenComplete((res, e) -> {