diff --git a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/common/TieredMessageStoreConfig.java b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/common/TieredMessageStoreConfig.java index 595db6b865c..a112ea6b102 100644 --- a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/common/TieredMessageStoreConfig.java +++ b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/common/TieredMessageStoreConfig.java @@ -115,7 +115,7 @@ public boolean check(TieredStorageLevel targetLevel) { private long readAheadCacheExpireDuration = 10 * 1000; private double readAheadCacheSizeThresholdRate = 0.3; - private String tieredStoreFilePath = ""; + private String tieredStoreFilepath = ""; private String objectStoreEndpoint = ""; @@ -350,12 +350,12 @@ public void setReadAheadCacheSizeThresholdRate(double rate) { this.readAheadCacheSizeThresholdRate = rate; } - public String getTieredStoreFilePath() { - return tieredStoreFilePath; + public String getTieredStoreFilepath() { + return tieredStoreFilepath; } - public void setTieredStoreFilePath(String tieredStoreFilePath) { - this.tieredStoreFilePath = tieredStoreFilePath; + public void setTieredStoreFilepath(String tieredStoreFilepath) { + this.tieredStoreFilepath = tieredStoreFilepath; } public void setObjectStoreEndpoint(String objectStoreEndpoint) { diff --git a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider/posix/PosixFileSegment.java b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider/posix/PosixFileSegment.java index 7e949cb28cc..708ce33f916 100644 --- a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider/posix/PosixFileSegment.java +++ b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider/posix/PosixFileSegment.java @@ -66,8 +66,8 @@ public PosixFileSegment(TieredMessageStoreConfig storeConfig, super(storeConfig, fileType, filePath, baseOffset); // basePath - String basePath = StringUtils.defaultString(storeConfig.getTieredStoreFilePath(), - StringUtils.appendIfMissing(storeConfig.getTieredStoreFilePath(), File.separator)); + String basePath = StringUtils.defaultString(storeConfig.getTieredStoreFilepath(), + StringUtils.appendIfMissing(storeConfig.getTieredStoreFilepath(), File.separator)); // fullPath: basePath/hash_cluster/broker/topic/queueId/fileType/baseOffset String brokerClusterName = storeConfig.getBrokerClusterName(); diff --git a/tieredstore/src/test/java/org/apache/rocketmq/tieredstore/file/TieredCommitLogTest.java b/tieredstore/src/test/java/org/apache/rocketmq/tieredstore/file/TieredCommitLogTest.java index 6693d3cb790..80cdba9778b 100644 --- a/tieredstore/src/test/java/org/apache/rocketmq/tieredstore/file/TieredCommitLogTest.java +++ b/tieredstore/src/test/java/org/apache/rocketmq/tieredstore/file/TieredCommitLogTest.java @@ -49,7 +49,7 @@ public void setUp() throws ClassNotFoundException, NoSuchMethodException { TieredMessageStoreConfig storeConfig = new TieredMessageStoreConfig(); storeConfig.setBrokerName("brokerName"); storeConfig.setStorePathRootDir(storePath); - storeConfig.setTieredStoreFilePath(storePath + File.separator); + storeConfig.setTieredStoreFilepath(storePath + File.separator); storeConfig.setTieredBackendServiceProvider("org.apache.rocketmq.tieredstore.provider.posix.PosixFileSegment"); storeConfig.setCommitLogRollingInterval(0); storeConfig.setTieredStoreCommitLogMaxSize(1000); diff --git a/tieredstore/src/test/java/org/apache/rocketmq/tieredstore/provider/posix/PosixFileSegmentTest.java b/tieredstore/src/test/java/org/apache/rocketmq/tieredstore/provider/posix/PosixFileSegmentTest.java index db33ae847f2..ede62b8ce92 100644 --- a/tieredstore/src/test/java/org/apache/rocketmq/tieredstore/provider/posix/PosixFileSegmentTest.java +++ b/tieredstore/src/test/java/org/apache/rocketmq/tieredstore/provider/posix/PosixFileSegmentTest.java @@ -42,7 +42,7 @@ public class PosixFileSegmentTest { @Before public void setUp() { storeConfig = new TieredMessageStoreConfig(); - storeConfig.setTieredStoreFilePath(storePath); + storeConfig.setTieredStoreFilepath(storePath); mq = new MessageQueue("OSSFileSegmentTest", "broker", 0); TieredStoreExecutor.init(); }