This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-4.1 by this push:
new 7215506308d [fix][broker] Fix transactionMetadataFuture
completeExceptionally with null value (#25231)
7215506308d is described below
commit 7215506308d6df0c49dda52fc89306b52d6231ca
Author: Hao Zhang <[email protected]>
AuthorDate: Mon Feb 9 19:15:58 2026 +0800
[fix][broker] Fix transactionMetadataFuture completeExceptionally with null
value (#25231)
Co-authored-by: 张浩 <[email protected]>
(cherry picked from commit 0e5d4246f3abc7235fd2547899742ecd85d4d593)
---
.../main/java/org/apache/pulsar/broker/admin/impl/TransactionsBase.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/TransactionsBase.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/TransactionsBase.java
index 55767136f81..e3764c89686 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/TransactionsBase.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/TransactionsBase.java
@@ -260,7 +260,7 @@ public abstract class TransactionsBase extends
AdminResource {
FutureUtil.waitForAll(producedPartitionsFutures).whenComplete((x,
t) -> {
if (t != null) {
- transactionMetadataFuture.completeExceptionally(e);
+ transactionMetadataFuture.completeExceptionally(t);
return;
}