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;
                 }
 

Reply via email to