Fixed - NPE thrown by RedisExecutor

4 years ago · 36491a3042
parent 3510d3294f
commit 36491a3042
1 changed files with 3 additions and 1 deletions
--- a/redisson/src/main/java/org/redisson/command/RedisExecutor.java
+++ b/redisson/src/main/java/org/redisson/command/RedisExecutor.java
@ -233,7 +233,9 @@ public class RedisExecutor<V, R> {

                if (attempt == attempts) {
                    // filled out in connectionFuture or writeFuture handler
-                    attemptPromise.tryFailure(exception);
+                    if (exception != null) {
+                        attemptPromise.tryFailure(exception);
+                    }
                    return;
                }
                if (!attemptPromise.cancel(false)) {