(pulsar) branch master updated: [fix][test] Fix flaky ManagedCursorTest.testSkipEntries (#25339)

[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 8114d5df0ad [fix][test] Fix flaky ManagedCursorTest.testSkipEntries 
(#25339)
8114d5df0ad is described below

commit 8114d5df0ad444971e193147482efcc2daad5632
Author: Matteo Merli <mme...@apache.org>
AuthorDate: Thu Mar 19 02:05:35 2026 -0700

    [fix][test] Fix flaky ManagedCursorTest.testSkipEntries (#25339)
---
 .../java/org/apache/bookkeeper/mledger/impl/ManagedCursorTest.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedCursorTest.java
 
b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedCursorTest.java
index 8c50e729dec..a3449298fd8 100644
--- 
a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedCursorTest.java
+++ 
b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedCursorTest.java
@@ -2133,7 +2133,9 @@ public class ManagedCursorTest extends 
MockedBookKeeperTestCase {
         Awaitility.await().untilAsserted(() -> {
             assertEquals(c1.getReadPosition().getEntryId(), 0);
         });
-        assertEquals(c1.getMarkDeletedPosition(), pos);
+        // The mark-delete position can be advanced beyond `pos` by 
TrimConsumedLedgers
+        // which runs asynchronously and may move it to the next ledger's -1 
position.
+        assertTrue(c1.getMarkDeletedPosition().compareTo(pos) >= 0);
     }
 
     @Test(timeOut = 20000, dataProvider = "useOpenRangeSet")