From 92fac4c10fc4afe23cd474dc3abcb4ef01c26a6b Mon Sep 17 00:00:00 2001 From: TheR1sing3un Date: Sun, 5 Mar 2023 18:27:45 +0800 Subject: [PATCH] fix(store): fix wrong value of MessageStoreConfig#storePathMetadata and storePathTempMetadata 1. fix wrong value of MessageStoreConfig#storePathMetadata and storePathTempMetadata --- .../rocketmq/store/config/MessageStoreConfig.java | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java b/store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java index 6019b245c9..3dd2db3e23 100644 --- a/store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java +++ b/store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java @@ -41,9 +41,11 @@ public class MessageStoreConfig { @ImportantField private String storePathEpochFile = null; - private String storePathMetadata = storePathRootDir + File.separator + "metadata"; + @ImportantField + private String storePathMetadata = null; - private String storePathTempMetadata = storePathRootDir + File.separator + "metadata-temp"; + @ImportantField + private String storePathTempMetadata = null; private String readOnlyCommitLogStorePaths = null; @@ -642,6 +644,9 @@ public class MessageStoreConfig { } public String getStorePathMetadata() { + if (storePathMetadata == null) { + return storePathRootDir + File.separator + "metadata"; + } return storePathMetadata; } @@ -650,6 +655,9 @@ public class MessageStoreConfig { } public String getStorePathTempMetadata() { + if (storePathTempMetadata == null) { + return storePathRootDir + File.separator + "metadata-temp"; + } return storePathTempMetadata; }