[pulsar] branch master updated: [fix][txn] Fix potentially unfinishable future. (#15208)

[eolivelli]

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

eolivelli 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 6aaabdb8acf [fix][txn] Fix potentially unfinishable future. (#15208)
6aaabdb8acf is described below

commit 6aaabdb8acfc9ecf07b1f2799b9d8e2a980343a5
Author: Qiang Zhao <74767115+mattisonc...@users.noreply.github.com>
AuthorDate: Tue Apr 19 14:31:20 2022 +0800

    [fix][txn] Fix potentially unfinishable future. (#15208)
---
 .../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;