(rocketmq) branch develop updated: [ISSUE #8032] Set checkDupInfo value from config

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 9d07cc7c51  [ISSUE #8032] Set checkDupInfo value from config
9d07cc7c51 is described below

commit 9d07cc7c51e127fc1cbb0593bd70652fa43b2939
Author: littleboy <2283985...@qq.com>
AuthorDate: Thu Apr 18 14:20:16 2024 +0800

     [ISSUE #8032] Set checkDupInfo value from config
---
 .../main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java  | 3 ++-
 1 file changed, 2 insertions(+), 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
index 27a18abc9d..e617343f9a 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
@@ -318,6 +318,7 @@ public class DLedgerCommitLog extends CommitLog {
 
     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 @@ public class DLedgerCommitLog extends CommitLog {
             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()) {