(pulsar) branch master updated: [fix][test] Fix thread leaks in ManagedLedgerTest and PulsarMockBookKeeper (#25377)

[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 109761ccd4d [fix][test] Fix thread leaks in ManagedLedgerTest and 
PulsarMockBookKeeper (#25377)
109761ccd4d is described below

commit 109761ccd4d87a6519ce0dc8a7ef2b42814b6b2f
Author: Matteo Merli <mme...@apache.org>
AuthorDate: Fri Mar 20 17:03:17 2026 -0700

    [fix][test] Fix thread leaks in ManagedLedgerTest and PulsarMockBookKeeper 
(#25377)
---
 .../test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java | 2 ++
 .../main/java/org/apache/bookkeeper/client/PulsarMockBookKeeper.java    | 2 +-
 2 files changed, 3 insertions(+), 1 deletion(-)

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 b06d4442ca7..353768a964e 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
@@ -4445,6 +4445,7 @@ public class ManagedLedgerTest extends 
MockedBookKeeperTestCase {
     public void testNonDurableCursorCreateForInactiveLedger() throws Exception 
{
         String mlName = "testLedgerInfoMetaCorrectIfAddEntryTimeOut";
         BookKeeper spyBookKeeper = spy(bkc);
+        @Cleanup("shutdown")
         ManagedLedgerFactoryImpl factory = new 
ManagedLedgerFactoryImpl(metadataStore, spyBookKeeper);
         ManagedLedgerConfig config = new ManagedLedgerConfig();
         initManagedLedgerConfig(config);
@@ -4498,6 +4499,7 @@ public class ManagedLedgerTest extends 
MockedBookKeeperTestCase {
     @Test
     public void testNoOrphanScheduledTasksAfterCloseML() throws Exception {
         String mlName = UUID.randomUUID().toString();
+        @Cleanup("shutdown")
         ManagedLedgerFactoryImpl factory = new 
ManagedLedgerFactoryImpl(metadataStore, bkc);
         ManagedLedgerConfig config = new ManagedLedgerConfig();
         initManagedLedgerConfig(config);
diff --git 
a/testmocks/src/main/java/org/apache/bookkeeper/client/PulsarMockBookKeeper.java
 
b/testmocks/src/main/java/org/apache/bookkeeper/client/PulsarMockBookKeeper.java
index c1f53d0adff..58fddb07ff9 100644
--- 
a/testmocks/src/main/java/org/apache/bookkeeper/client/PulsarMockBookKeeper.java
+++ 
b/testmocks/src/main/java/org/apache/bookkeeper/client/PulsarMockBookKeeper.java
@@ -306,7 +306,7 @@ public class PulsarMockBookKeeper extends BookKeeper {
             ledger.entries.clear();
             ledger.totalLengthCounter.set(0);
         }
-        scheduler.shutdown();
+        scheduler.shutdownNow();
         ledgers.clear();
     }