We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 090ff24 commit d8eb65dCopy full SHA for d8eb65d
pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
@@ -600,6 +600,9 @@ public CompletableFuture<Void> closeAsync() {
600
if (transactionExecutorProvider != null) {
601
transactionExecutorProvider.shutdownNow();
602
}
603
+ if (transactionTimer != null) {
604
+ transactionTimer.stop();
605
+ }
606
MLPendingAckStoreProvider.closeBufferedWriterMetrics();
607
MLTransactionMetadataStoreProvider.closeBufferedWriterMetrics();
608
if (this.offloaderStats != null) {
0 commit comments