(pulsar) branch branch-4.2 updated: [fix][test][branch-4.2] Fix PersistentMessageExpiryMonitorTest

[lhotari]

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

lhotari pushed a commit to branch branch-4.2
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-4.2 by this push:
     new e6faf75cf76 [fix][test][branch-4.2] Fix 
PersistentMessageExpiryMonitorTest
e6faf75cf76 is described below

commit e6faf75cf76f35bce0dc48839c9c51c5e96d7a5d
Author: Lari Hotari <lhot...@apache.org>
AuthorDate: Mon Jun 1 23:59:29 2026 +0300

    [fix][test][branch-4.2] Fix PersistentMessageExpiryMonitorTest
    
    - master branch contains this change
      - the second parameter will also match a null value
---
 .../bookkeeper/mledger/impl/PersistentMessageExpiryMonitorTest.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/bookkeeper/mledger/impl/PersistentMessageExpiryMonitorTest.java
 
b/pulsar-broker/src/test/java/org/apache/bookkeeper/mledger/impl/PersistentMessageExpiryMonitorTest.java
index de7d87e4293..c2163a1c130 100644
--- 
a/pulsar-broker/src/test/java/org/apache/bookkeeper/mledger/impl/PersistentMessageExpiryMonitorTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/bookkeeper/mledger/impl/PersistentMessageExpiryMonitorTest.java
@@ -24,7 +24,6 @@ import static org.mockito.ArgumentMatchers.anyLong;
 import static org.mockito.Mockito.doAnswer;
 import static org.mockito.Mockito.spy;
 import static org.testng.AssertJUnit.assertEquals;
-import java.util.Map;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
@@ -100,7 +99,7 @@ public class PersistentMessageExpiryMonitorTest extends 
ProducerConsumerBase {
                 }
             });
             return true;
-        }).when(spyCursor).asyncMarkDelete(any(Position.class), any(Map.class),
+        }).when(spyCursor).asyncMarkDelete(any(Position.class), any(),
                 any(AsyncCallbacks.MarkDeleteCallback.class), any());
         doAnswer(invocationOnMock -> {
             calledFindPositionCount.incrementAndGet();