opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-10-31 02:57:35 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #2663] Fix isSpaceFull print file path not exist log When deployed on DLedger mode

Browse Source 
Co-authored-by: zhangxu16 <zhangxu16@xiaomi.com>
This commit is contained in:
张旭
2021-02-08 18:46:37 +08:00
committed by GitHub
co-authored by zhangxu16
parent b94ef842de
commit ccc4b6db67
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
+1 -2
View File
@@ -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);