Skip to content

Commit 5e734b6

Browse files
committed
[fix][broker] Fix HashedWheelTimer leak in PulsarService by stopping it in shutdown (#24275)
(cherry picked from commit 1280672)
1 parent c6419a9 commit 5e734b6

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -659,6 +659,9 @@ public CompletableFuture<Void> closeAsync() {
659659
if (transactionExecutorProvider != null) {
660660
transactionExecutorProvider.shutdownNow();
661661
}
662+
if (transactionTimer != null) {
663+
transactionTimer.stop();
664+
}
662665
MLPendingAckStoreProvider.closeBufferedWriterMetrics();
663666
MLTransactionMetadataStoreProvider.closeBufferedWriterMetrics();
664667
if (this.offloaderStats != null) {

0 commit comments

Comments
 (0)