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();