This is an automated email from the ASF dual-hosted git repository. penghui pushed a commit to branch branch-2.10 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 84a08942dd2754a758b94aa3db9b292d894b2f2e Author: Qiang Zhao <[email protected]> AuthorDate: Tue Apr 19 14:31:20 2022 +0800 [fix][txn] Fix potentially unfinishable future. (#15208) (cherry picked from commit 6aaabdb8acfc9ecf07b1f2799b9d8e2a980343a5) --- .../org/apache/pulsar/broker/TransactionMetadataStoreService.java | 6 +++++- 1 file changed, 5 insertions(+), 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 index cd188397989..902546958c5 100644 --- 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 class TransactionMetadataStoreService { 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;
