From ccc4b6db67d93efd9cdc2b81fa36c8b55f3f00a8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E6=97=AD?= Date: Mon, 8 Feb 2021 18:46:37 +0800 Subject: [PATCH] [ISSUE #2663] Fix isSpaceFull print file path not exist log When deployed on DLedger mode Co-authored-by: zhangxu16 --- .../java/org/apache/rocketmq/store/DefaultMessageStore.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java index eff46772..14a8848b 100644 --- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java +++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java @@ -1747,8 +1747,7 @@ public class DefaultMessageStore implements MessageStore { this.manualDeleteFileSeveralTimes = manualDeleteFileSeveralTimes; } public boolean isSpaceFull() { - String storePathPhysic = DefaultMessageStore.this.getMessageStoreConfig().getStorePathCommitLog(); - double physicRatio = UtilAll.getDiskPartitionSpaceUsedPercent(storePathPhysic); + double physicRatio = UtilAll.getDiskPartitionSpaceUsedPercent(getStorePathPhysic()); double ratio = DefaultMessageStore.this.getMessageStoreConfig().getDiskMaxUsedSpaceRatio() / 100.0; if (physicRatio > ratio) { DefaultMessageStore.log.info("physic disk of commitLog used: " + physicRatio); -- GitLab