[fix][test] fix flaky test testRecoverSequenceId (apache#18437)

lifepuzzlefun · Jan 10, 2023 · a2d74eb · a2d74eb
1 parent 6a14607
commit a2d74eb
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...c/test/java/org/apache/pulsar/transaction/coordinator/MLTransactionMetadataStoreTest.java b/...c/test/java/org/apache/pulsar/transaction/coordinator/MLTransactionMetadataStoreTest.java
@@ -196,9 +196,8 @@ public void testRecoverSequenceId(boolean isUseManagedLedgerProperties) throws E
             stateUpdater.setAccessible(true);
             stateUpdater.set(managedLedger, ManagedLedgerImpl.State.LedgerOpened);
             managedLedger.rollCurrentLedgerIfFull();
-            Awaitility.await().until(() -> {
-                return !managedLedger.ledgerExists(position.getLedgerId());
-            });
+            //There is new ledger been created
+            Awaitility.await().until(() -> managedLedger.getLedgersInfo().ceilingEntry(position.getLedgerId()) != null);
         }
         mlTransactionLog.closeAsync().get(2, TimeUnit.SECONDS);
         mlTransactionLog = new MLTransactionLogImpl(transactionCoordinatorID, factory,