From b31c17f9e2ea62606b57655526c9a83dbdddc982 Mon Sep 17 00:00:00 2001
From: dongeforever <dongeforever@apache.org>
Date: Mon, 3 Dec 2018 17:13:02 +0800
Subject: [PATCH] Load and recover for dledger commitlog

---
 .../org/apache/rocketmq/store/dledger/DLedgerCommitLog.java   | 4 ++++
 1 file changed, 4 insertions(+)

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 02d96a86..5945b851 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);
         }
-- 
GitLab