(pulsar) branch master updated: [fix][test] Fix flaky testRetentionSize in ManagedLedgerTest (#25423)

[lhotari]

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

lhotari 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 20777df8ea8 [fix][test] Fix flaky testRetentionSize in 
ManagedLedgerTest (#25423)
20777df8ea8 is described below

commit 20777df8ea83571af92c9ee3ab9e228dcbf9cbd6
Author: Matteo Merli <mme...@apache.org>
AuthorDate: Mon Mar 30 15:51:17 2026 -0700

    [fix][test] Fix flaky testRetentionSize in ManagedLedgerTest (#25423)
---
 .../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 ac292e1fe15..b1066c297c4 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
@@ -2490,8 +2490,9 @@ public class ManagedLedgerTest extends 
MockedBookKeeperTestCase {
         for (int i = 0; i < totalMessage; i++) {
             position = ml.addEntry(message);
         }
-        // all ledgers are not delete yet since no entry has been acked for c1
-        assertEquals(ml.getLedgersInfoAsList().size(), totalMessage);
+        // all ledgers are not deleted yet since no entry has been acked for c1
+        // Use >= because the current (empty) ledger may or may not have been 
created yet
+        assertTrue(ml.getLedgersInfoAsList().size() >= totalMessage);
 
         List<Entry> entryList = c1.readEntries(totalMessage);
         if (null != position) {