diff --git a/java/client/src/main/java/glide/api/RedisClusterClient.java b/java/client/src/main/java/glide/api/RedisClusterClient.java index b288d7b70f..cfdf1bd072 100644 --- a/java/client/src/main/java/glide/api/RedisClusterClient.java +++ b/java/client/src/main/java/glide/api/RedisClusterClient.java @@ -71,14 +71,14 @@ protected ClusterValue handleCustomCommandResponse(Route route, Response @Override public CompletableFuture exec(ClusterTransaction transaction) { return commandManager.submitNewCommand( - transaction, Optional.empty(), this::handleArrayOrNullResponse); + transaction, Optional.empty(), this::handleArrayResponse); } @Override public CompletableFuture[]> exec( ClusterTransaction transaction, Route route) { return commandManager - .submitNewCommand(transaction, Optional.ofNullable(route), this::handleArrayOrNullResponse) + .submitNewCommand(transaction, Optional.ofNullable(route), this::handleArrayResponse) .thenApply( objects -> Arrays.stream(objects)