This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit d8eb65d831f4292c611e64fe2c2ec1e999076a48 Author: Lari Hotari <[email protected]> AuthorDate: Thu May 8 20:15:06 2025 +0300 [fix][broker] Fix HashedWheelTimer leak in PulsarService by stopping it in shutdown (#24275) (cherry picked from commit 12806727c8eb8cf17fded4ef11e786718b432444) --- .../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 8486ebfa1a3..f7325653305 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 @@ -600,6 +600,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) {
