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

[ji...@apache.org]

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 <cs...@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);