[Tests] Fix flaky test TransactionMetadataStoreServiceTest.transactio…

…nTimeoutRecoverTest (apache#10313) Fixes apache#10310
xche · Apr 21, 2021 · fda4cd6 · fda4cd6
1 parent 424eaec
commit fda4cd6
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/...r/src/test/java/org/apache/pulsar/broker/service/TransactionMetadataStoreServiceTest.java b/...r/src/test/java/org/apache/pulsar/broker/service/TransactionMetadataStoreServiceTest.java
@@ -282,7 +282,6 @@ public void transactionTimeoutRecoverTest() throws Exception {
         field.setAccessible(true);
         ConcurrentMap<TxnID, Pair<TxnMeta, List<Position>>> txnMap =
                 (ConcurrentMap<TxnID, Pair<TxnMeta, List<Position>>>) field.get(transactionMetadataStore);
-        assertEquals(txnMap.size(), 1);
         Awaitility.await().atMost(3000, TimeUnit.MILLISECONDS).until(() -> txnMap.size() == 0);
 
     }