We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4b5f866 commit b1a7ac8Copy full SHA for b1a7ac8
1 file changed
store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
@@ -2241,7 +2241,7 @@ public String getServiceName() {
2241
private boolean isSpaceToDelete() {
2242
cleanImmediately = false;
2243
2244
- String commitLogStorePath = DefaultMessageStore.this.getMessageStoreConfig().getStorePathCommitLog();
+ String commitLogStorePath = DefaultMessageStore.this.getStorePathPhysic();
2245
String[] storePaths = commitLogStorePath.trim().split(MixAll.MULTI_PATH_SPLITTER);
2246
Set<String> fullStorePath = new HashSet<>();
2247
double minPhysicRatio = 100;
0 commit comments