(pulsar) branch master updated: [fix][broker] Fix transactionMetadataFuture completeExceptionally with null value (#25231)

[lhotari]

This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 0e5d4246f3a [fix][broker] Fix transactionMetadataFuture 
completeExceptionally with null value (#25231)
0e5d4246f3a is described below

commit 0e5d4246f3abc7235fd2547899742ecd85d4d593
Author: Hao Zhang <zhangh...@cmss.chinamobile.com>
AuthorDate: Mon Feb 9 19:15:58 2026 +0800

    [fix][broker] Fix transactionMetadataFuture completeExceptionally with null 
value (#25231)
    
    Co-authored-by: 张浩 <zhangha...@100.me>
---
 .../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;
                 }