From adbfe2a425d3a7d5efce7e1b4590050034375a4e Mon Sep 17 00:00:00 2001 From: mxsm Date: Tue, 18 Mar 2025 23:58:38 +0800 Subject: [PATCH] [ISSUE #9259]Remove the duplicate flushing of storeCheckpoint --- .../main/java/org/apache/rocketmq/store/DefaultMessageStore.java | 1 - 1 file changed, 1 deletion(-) diff --git a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java index d293e49a50a..d6134683861 100644 --- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java +++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java @@ -522,7 +522,6 @@ public void shutdown() { } this.flushConsumeQueueService.shutdown(); this.allocateMappedFileService.shutdown(); - this.storeCheckpoint.flush(); this.storeCheckpoint.shutdown(); this.perfs.shutdown();