This is an automated email from the ASF dual-hosted git repository.
hangxiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 9a7b976364d2c93e064fb985d51e9bdee672cac6
Author: wangfeifan <zoltar9...@163.com>
AuthorDate: Mon May 27 19:00:40 2024 +0800
[hotfix][statebackend] Normalize ForSt option names
---
.../src/main/java/org/apache/flink/state/forst/ForStOptions.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStOptions.java
b/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStOptions.java
index c0bd1e123a6..2ff6d2e1534 100644
---
a/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStOptions.java
+++
b/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStOptions.java
@@ -32,7 +32,7 @@ public class ForStOptions {
/** The local directory (on the TaskManager) where ForSt puts some meta
files. */
public static final ConfigOption<String> LOCAL_DIRECTORIES =
- ConfigOptions.key("state.backend.forst.localdir")
+ ConfigOptions.key("state.backend.forst.local-dir")
.stringType()
.noDefaultValue()
.withDescription(
@@ -47,7 +47,7 @@ public class ForStOptions {
/** The remote directory where ForSt puts its SST files. */
public static final ConfigOption<String> REMOTE_DIRECTORY =
- ConfigOptions.key("state.backend.forst.remotedir")
+ ConfigOptions.key("state.backend.forst.remote-dir")
.stringType()
.noDefaultValue()
.withDescription(
