This is an automated email from the ASF dual-hosted git repository. penghui pushed a commit to branch branch-2.10 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit cafeadedf078d8cc412b5631c9f0c81e352d813f Author: 包子 <[email protected]> AuthorDate: Thu Mar 3 16:36:54 2022 +0800 [Flaky-test]: Fix MLTransactionMetadataStoreTest.testInitTransactionReader fails sporadically (#14532) ### Motivation #14525 When update states is `TxnStatus.COMMITTED`, Not correctly `completableFuture.complete`. ### Modifications - When update states is `TxnStatus.COMMITTED`, Add return to ending. Avoid direct calls `completableFuture.complete` from other logic. ### Documentation - [x ] `no-need-doc` (cherry picked from commit c15d0ef24e37df6b86bc8f4c27d43af27f8cc663) --- .../pulsar/transaction/coordinator/impl/MLTransactionMetadataStore.java | 1 + 1 file changed, 1 insertion(+) diff --git a/pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/MLTransactionMetadataStore.java b/pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/MLTransactionMetadataStore.java index b4100de..19d651c 100644 --- a/pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/MLTransactionMetadataStore.java +++ b/pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/MLTransactionMetadataStore.java @@ -393,6 +393,7 @@ public class MLTransactionMetadataStore txnMetaMap.remove(txnID.getLeastSigBits()); completableFuture.complete(null); }); + return; } completableFuture.complete(null); } catch (InvalidTxnStatusException e) {
