This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 2b85b8752b5 [fix][broker] Fix transactionMetadataFuture
completeExceptionally with null value (#25231)
2b85b8752b5 is described below
commit 2b85b8752b5ae00fb197e19ccd0476335e5e860a
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 b322cc824f6..69cf8ce2dce 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
@@ -254,7 +254,7 @@ public abstract class TransactionsBase extends
AdminResource {
FutureUtil.waitForAll(producedPartitionsFutures).whenComplete((x,
t) -> {
if (t != null) {
- transactionMetadataFuture.completeExceptionally(e);
+ transactionMetadataFuture.completeExceptionally(t);
return;
}