[rocketmq] branch develop updated: [ISSUE #4211] Fix diskMaxUsedSpaceRatio does not take effect in dLedger

[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 df3f8de4c [ISSUE #4211] Fix diskMaxUsedSpaceRatio does not take effect 
in dLedger
df3f8de4c is described below

commit df3f8de4c03a282de052b130ae368ab00faca039
Author: cserwen <cser...@163.com>
AuthorDate: Fri Apr 29 10:12:51 2022 +0800

    [ISSUE #4211] Fix diskMaxUsedSpaceRatio does not take effect in dLedger
---
 .../main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java    | 1 +
 1 file changed, 1 insertion(+)

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 01266ede7..b8f037369 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
@@ -101,6 +101,7 @@ public class DLedgerCommitLog extends CommitLog {
         
dLedgerConfig.setFileReservedHours(defaultMessageStore.getMessageStoreConfig().getFileReservedTime()
 + 1);
         
dLedgerConfig.setPreferredLeaderId(defaultMessageStore.getMessageStoreConfig().getPreferredLeaderId());
         
dLedgerConfig.setEnableBatchPush(defaultMessageStore.getMessageStoreConfig().isEnableBatchPush());
+        
dLedgerConfig.setDiskSpaceRatioToCheckExpired(defaultMessageStore.getMessageStoreConfig().getDiskMaxUsedSpaceRatio()
 / 100f);
 
         id = Integer.parseInt(dLedgerConfig.getSelfId().substring(1)) + 1;
         dLedgerServer = new DLedgerServer(dLedgerConfig);