Skip to content

Commit ad70fbc

Browse files
lhotarisrinath-ctds
authored andcommitted
[fix][broker] Fix HashedWheelTimer leak in PulsarService by stopping it in shutdown (apache#24275)
(cherry picked from commit 1280672) (cherry picked from commit d8eb65d)
1 parent 9143237 commit ad70fbc

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
@@ -607,6 +607,9 @@ public CompletableFuture<Void> closeAsync() {
607607
if (transactionExecutorProvider != null) {
608608
transactionExecutorProvider.shutdownNow();
609609
}
610+
if (transactionTimer != null) {
611+
transactionTimer.stop();
612+
}
610613
MLPendingAckStoreProvider.closeBufferedWriterMetrics();
611614
MLTransactionMetadataStoreProvider.closeBufferedWriterMetrics();
612615
if (this.offloaderStats != null) {

0 commit comments

Comments
 (0)