(pulsar) branch master updated: [fix][test] Fix flaky ManagedLedgerTest.testNoRetention (#25467)

[zixuan]

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

zixuan 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 8d9d4976fee [fix][test] Fix flaky ManagedLedgerTest.testNoRetention 
(#25467)
8d9d4976fee is described below

commit 8d9d4976fee3509722af525e0d05513d3576a620
Author: Matteo Merli <mme...@apache.org>
AuthorDate: Mon Apr 6 20:29:22 2026 -0700

    [fix][test] Fix flaky ManagedLedgerTest.testNoRetention (#25467)
---
 .../java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java  | 6 ++++--
 1 file changed, 4 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 3b63bb869c6..2a6c7e4a73b 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
@@ -2309,8 +2309,10 @@ public class ManagedLedgerTest extends 
MockedBookKeeperTestCase {
         c1 = ml.openCursor("c1noretention");
         ml.addEntry("shortmessage".getBytes());
         c1.skipEntries(1, IndividualDeletedEntries.Exclude);
-        // sleep for trim
-        Thread.sleep(1000);
+        // Explicitly trigger trimming and wait for it to complete
+        CompletableFuture<Void> trimFuture = new CompletableFuture<>();
+        ml.trimConsumedLedgersInBackground(trimFuture);
+        trimFuture.join();
         ml.close();
 
         assertTrue(ml.getLedgersInfoAsList().size() <= 1);