(pulsar) branch master updated: [fix][test] Fix thread leaks in ClientDeduplicationFailureTest and RackAwareTest (#25374)

[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 a27988bc109 [fix][test] Fix thread leaks in 
ClientDeduplicationFailureTest and RackAwareTest (#25374)
a27988bc109 is described below

commit a27988bc109e35a1b5efd82cce3b4f789a48d724
Author: Matteo Merli <mme...@apache.org>
AuthorDate: Fri Mar 20 17:06:36 2026 -0700

    [fix][test] Fix thread leaks in ClientDeduplicationFailureTest and 
RackAwareTest (#25374)
---
 .../src/test/java/org/apache/pulsar/broker/service/RackAwareTest.java | 4 ++--
 .../org/apache/pulsar/client/api/ClientDeduplicationFailureTest.java  | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/RackAwareTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/RackAwareTest.java
index e3863b6d10e..83b49d5c5a3 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/RackAwareTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/RackAwareTest.java
@@ -96,12 +96,12 @@ public class RackAwareTest extends BkEnsemblesTestBase {
     @Override
     @AfterMethod(alwaysRun = true)
     protected void cleanup() throws Exception {
-        super.cleanup();
-
         for (ServerTester t : servers) {
             t.shutdown();
         }
         servers.clear();
+
+        super.cleanup();
     }
 
     @Test
diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ClientDeduplicationFailureTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ClientDeduplicationFailureTest.java
index 5fede49b16e..c0249c9e98e 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ClientDeduplicationFailureTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/ClientDeduplicationFailureTest.java
@@ -130,7 +130,7 @@ public class ClientDeduplicationFailureTest {
         log.info("--- Shutting down ---");
         if (pulsarClient != null) {
             pulsarClient.close();
-            pulsar = null;
+            pulsarClient = null;
         }
         if (admin != null) {
             admin.close();