This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 4791d9a1f1 [ISSUE #5923] Revert "Fix tiered store README.md error
about Configuration (#7436)" (#7557)
4791d9a1f1 is described below
commit 4791d9a1f1a7c39e005da15f228473c04eafd007
Author: lizhimins <[email protected]>
AuthorDate: Tue Nov 14 17:59:47 2023 +0800
[ISSUE #5923] Revert "Fix tiered store README.md error about Configuration
(#7436)" (#7557)
This reverts commit 70dc93abbcb9bf161378d66fcaca55bedc78b905.
---
.../rocketmq/tieredstore/common/TieredMessageStoreConfig.java | 10 +++++-----
.../rocketmq/tieredstore/provider/posix/PosixFileSegment.java | 4 ++--
.../apache/rocketmq/tieredstore/file/TieredCommitLogTest.java | 2 +-
.../tieredstore/provider/posix/PosixFileSegmentTest.java | 2 +-
4 files changed, 9 insertions(+), 9 deletions(-)
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 a112ea6b10..595db6b865 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 class TieredMessageStoreConfig {
private long readAheadCacheExpireDuration = 10 * 1000;
private double readAheadCacheSizeThresholdRate = 0.3;
- private String tieredStoreFilepath = "";
+ private String tieredStoreFilePath = "";
private String objectStoreEndpoint = "";
@@ -350,12 +350,12 @@ public class TieredMessageStoreConfig {
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 708ce33f91..7e949cb28c 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 class PosixFileSegment extends TieredFileSegment {
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 80cdba9778..6693d3cb79 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 class TieredCommitLogTest {
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 ede62b8ce9..db33ae847f 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();
}