[fix][txn] Fix potentially unfinishable future. (#15208)

(cherry picked from commit 6aaabdb)
apache · Apr 28, 2022 · 84a0894 · 84a0894
1 parent 3ebc23e
commit 84a0894
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/TransactionMetadataStoreService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/TransactionMetadataStoreService.java
@@ -243,7 +243,11 @@ public CompletableFuture<Void> handleTcClientConnect(TransactionCoordinatorID tc
                             LOG.debug("Handle tc client connect added into pending queue! tcId : {}", tcId.toString());
                         }
                     }
-                }));
+                })).exceptionally(ex -> {
+                    Throwable realCause = FutureUtil.unwrapCompletionException(ex);
+                    completableFuture.completeExceptionally(realCause);
+                    return null;
+                });
             }
         });
         return completableFuture;