You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2022/04/28 13:04:09 UTC
[pulsar] 05/26: [fix][txn] Fix potentially unfinishable future. (#15208)
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 <74...@users.noreply.github.com>
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;