[pulsar] branch master updated: [Flaky-test]: Fix MLTransactionMetadataStoreTest.testInitTransactionReader fails sporadically (#14532)

[shoothzj]

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

shoothzj 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 c15d0ef  [Flaky-test]: Fix 
MLTransactionMetadataStoreTest.testInitTransactionReader fails sporadically 
(#14532)
c15d0ef is described below

commit c15d0ef24e37df6b86bc8f4c27d43af27f8cc663
Author: 包子 <wudixiaolong...@gmail.com>
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`
---
 .../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) {