You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2025/05/09 19:01:29 UTC
(pulsar) 09/15: [fix][broker] Fix HashedWheelTimer leak in PulsarService by stopping it in shutdown (#24275)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit b4a4d592028acd1d60489b5d8fe778e680db55f1
Author: Lari Hotari <lh...@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)
(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 308c3459065..5551df0b0ab 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
@@ -643,6 +643,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) {