(pulsar) branch master updated: [fix][broker] Fix HashedWheelTimer leak in PulsarService by stopping it in shutdown (#24275)

[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 12806727c8e [fix][broker] Fix HashedWheelTimer leak in PulsarService 
by stopping it in shutdown (#24275)
12806727c8e is described below

commit 12806727c8eb8cf17fded4ef11e786718b432444
Author: Lari Hotari <lhot...@users.noreply.github.com>
AuthorDate: Thu May 8 20:15:06 2025 +0300

    [fix][broker] Fix HashedWheelTimer leak in PulsarService by stopping it in 
shutdown (#24275)
---
 .../src/main/java/org/apache/pulsar/broker/PulsarService.java          | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
index 51eecb53f9d..1a55b95852a 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
@@ -661,6 +661,9 @@ public class PulsarService implements AutoCloseable, 
ShutdownService {
             if (transactionExecutorProvider != null) {
                 transactionExecutorProvider.shutdownNow();
             }
+            if (transactionTimer != null) {
+                transactionTimer.stop();
+            }
             MLPendingAckStoreProvider.closeBufferedWriterMetrics();
             MLTransactionMetadataStoreProvider.closeBufferedWriterMetrics();
             if (this.offloaderStats != null) {