[ISSUE apache#8032] Set checkDupInfo value from config

Jianing-Xu · Apr 18, 2024 · 9d07cc7 · 9d07cc7
1 parent ac5545c
commit 9d07cc7
Showing 1 changed file with 2 additions and 1 deletion.
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
@@ -318,6 +318,7 @@ private void dledgerRecoverNormally(long maxPhyOffsetOfConsumeQueue) throws Rock
 
     private void dledgerRecoverAbnormally(long maxPhyOffsetOfConsumeQueue) throws RocksDBException {
         boolean checkCRCOnRecover = this.defaultMessageStore.getMessageStoreConfig().isCheckCRCOnRecover();
+        boolean checkDupInfo = this.defaultMessageStore.getMessageStoreConfig().isDuplicationEnable();
         dLedgerFileStore.load();
         if (!dLedgerFileList.getMappedFiles().isEmpty()) {
             dLedgerFileStore.recover();
@@ -346,7 +347,7 @@ private void dledgerRecoverAbnormally(long maxPhyOffsetOfConsumeQueue) throws Ro
             long processOffset = mmapFile.getFileFromOffset();
             long mmapFileOffset = 0;
             while (true) {
-                DispatchRequest dispatchRequest = this.checkMessageAndReturnSize(byteBuffer, checkCRCOnRecover, true);
+                DispatchRequest dispatchRequest = this.checkMessageAndReturnSize(byteBuffer, checkCRCOnRecover, checkDupInfo);
                 int size = dispatchRequest.getMsgSize();
 
                 if (dispatchRequest.isSuccess()) {