This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.3 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 9c1443bf3c3db8126018029ace68d43b2574097e Author: Jiawen Wang <[email protected]> AuthorDate: Sun Oct 13 22:56:55 2024 +0800 [fix][test] Fix flaky test ManagedLedgerTest.testDeleteCurrentLedgerWhenItIsClosed (#23437) (cherry picked from commit aa6bc0929bf28f5e8498ddb2055057b078d46481) --- .../java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java index 166cb468d0f..00d2660953a 100644 --- a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java +++ b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java @@ -4357,9 +4357,10 @@ public class ManagedLedgerTest extends MockedBookKeeperTestCase { // Detect the current ledger is full by the timed task. (Imitate: the timed task `checkLedgerRollTask` call // `rollCurrentLedgerIfFull` periodically). ml.rollCurrentLedgerIfFull(); - // the ledger closing in the `rollCurrentLedgerIfFull` is async, so the wait is needed. - Awaitility.await().untilAsserted(() -> assertEquals(ml.ledgers.size(), 2)); } + // wait the new ledger create + Awaitility.await().untilAsserted(() -> assertEquals(ml.ledgers.size(), 2)); + // Act: Trigger trimming to delete the previous current ledger. ml.internalTrimLedgers(false, Futures.NULL_PROMISE); // Verify: A new ledger will be opened after the current ledger is closed and the previous current ledger can be
