diff --git a/store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java b/store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java index 02d96a8684..5945b851b9 100644 --- a/store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java +++ b/store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java @@ -263,6 +263,8 @@ public class DLedgerCommitLog extends CommitLog { @Override public void recoverAbnormally(long maxPhyOffsetOfConsumeQueue) { + dLedgerFileStore.load(); + dLedgerFileStore.recover(); if (dLedgerFileList.getMappedFiles().isEmpty()) { super.recoverAbnormally(maxPhyOffsetOfConsumeQueue); } @@ -270,6 +272,8 @@ public class DLedgerCommitLog extends CommitLog { @Override public void recoverNormally(long maxPhyOffsetOfConsumeQueue) { + dLedgerFileStore.load(); + dLedgerFileStore.recover(); if (dLedgerFileList.getMappedFiles().isEmpty()) { super.recoverNormally(maxPhyOffsetOfConsumeQueue); }