This is an automated email from the ASF dual-hosted git repository.
RocMarshal pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 72bcee7aee1 [FLINK-40815][configuration] Remove the deprecated
configuration keys from the flink-dstl-dfs module.
72bcee7aee1 is described below
commit 72bcee7aee198df22d6a9c39b8f65c68f4f4c922
Author: Yuepeng Pan <[email protected]>
AuthorDate: Fri Sep 25 16:45:38 2026 +0800
[FLINK-40815][configuration] Remove the deprecated configuration keys from
the flink-dstl-dfs module.
---
.../apache/flink/changelog/fs/FsStateChangelogOptions.java | 14 --------------
1 file changed, 14 deletions(-)
diff --git
a/flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogOptions.java
b/flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogOptions.java
index 1704fa82e57..9f9ecd4d37d 100644
---
a/flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogOptions.java
+++
b/flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogOptions.java
@@ -33,21 +33,18 @@ public class FsStateChangelogOptions {
ConfigOptions.key("state.changelog.dstl.dfs.base-path")
.stringType()
.noDefaultValue()
- .withDeprecatedKeys("dstl.dfs.base-path")
.withDescription("Base path to store changelog files.");
public static final ConfigOption<Boolean> COMPRESSION_ENABLED =
ConfigOptions.key("state.changelog.dstl.dfs.compression.enabled")
.booleanType()
.defaultValue(false)
- .withDeprecatedKeys("dstl.dfs.compression.enabled")
.withDescription("Whether to enable compression when
serializing changelog.");
public static final ConfigOption<MemorySize> PREEMPTIVE_PERSIST_THRESHOLD =
ConfigOptions.key("state.changelog.dstl.dfs.preemptive-persist-threshold")
.memoryType()
.defaultValue(MemorySize.parse("5MB"))
-
.withDeprecatedKeys("dstl.dfs.preemptive-persist-threshold")
.withDescription(
"Size threshold for state changes of a single
operator "
+ "beyond which they are persisted
pre-emptively without waiting for a checkpoint. "
@@ -58,7 +55,6 @@ public class FsStateChangelogOptions {
ConfigOptions.key("state.changelog.dstl.dfs.batch.persist-delay")
.durationType()
.defaultValue(Duration.ofMillis(10))
- .withDeprecatedKeys("dstl.dfs.batch.persist-delay")
.withDescription(
"Delay before persisting changelog after receiving
persist request (on checkpoint). "
+ "Minimizes the number of files and
requests "
@@ -69,7 +65,6 @@ public class FsStateChangelogOptions {
ConfigOptions.key("state.changelog.dstl.dfs.batch.persist-size-threshold")
.memoryType()
.defaultValue(MemorySize.parse("10MB"))
-
.withDeprecatedKeys("dstl.dfs.batch.persist-size-threshold")
.withDescription(
"Size threshold for state changes that were
requested to be persisted but are waiting for "
+ PERSIST_DELAY.key()
@@ -84,21 +79,18 @@ public class FsStateChangelogOptions {
ConfigOptions.key("state.changelog.dstl.dfs.upload.buffer-size")
.memoryType()
.defaultValue(MemorySize.parse("1MB"))
- .withDeprecatedKeys("dstl.dfs.upload.buffer-size")
.withDescription("Buffer size used when uploading change
sets");
public static final ConfigOption<Integer> NUM_UPLOAD_THREADS =
ConfigOptions.key("state.changelog.dstl.dfs.upload.num-threads")
.intType()
.defaultValue(5)
- .withDeprecatedKeys("dstl.dfs.upload.num-threads")
.withDescription("Number of threads to use for upload.");
public static final ConfigOption<Integer> NUM_DISCARD_THREADS =
ConfigOptions.key("state.changelog.dstl.dfs.discard.num-threads")
.intType()
.defaultValue(1)
- .withDeprecatedKeys("dstl.dfs.discard.num-threads")
.withDescription(
"Number of threads to use to discard changelog
(e.g. pre-emptively uploaded unused state).");
@@ -106,7 +98,6 @@ public class FsStateChangelogOptions {
ConfigOptions.key("state.changelog.dstl.dfs.upload.max-in-flight")
.memoryType()
.defaultValue(MemorySize.parse("100MB"))
- .withDeprecatedKeys("dstl.dfs.upload.max-in-flight")
.withDescription(
"Max amount of data allowed to be in-flight. "
+ "Upon reaching this limit the task will
be back-pressured. "
@@ -122,14 +113,12 @@ public class FsStateChangelogOptions {
ConfigOptions.key("state.changelog.dstl.dfs.upload.retry-policy")
.stringType()
.defaultValue("fixed")
- .withDeprecatedKeys("dstl.dfs.upload.retry-policy")
.withDescription(
"Retry policy for the failed uploads (in
particular, timed out). Valid values: none, fixed.");
public static final ConfigOption<Duration> UPLOAD_TIMEOUT =
ConfigOptions.key("state.changelog.dstl.dfs.upload.timeout")
.durationType()
.defaultValue(Duration.ofSeconds(1))
- .withDeprecatedKeys("dstl.dfs.upload.timeout")
.withDescription(
"Time threshold beyond which an upload is
considered timed out. "
+ "If a new attempt is made but this
upload succeeds earlier then this upload result will be used. "
@@ -143,7 +132,6 @@ public class FsStateChangelogOptions {
ConfigOptions.key("state.changelog.dstl.dfs.upload.max-attempts")
.intType()
.defaultValue(3)
- .withDeprecatedKeys("dstl.dfs.upload.max-attempts")
.withDescription(
"Maximum number of attempts (including the initial
one) to perform a particular upload. "
+ "Only takes effect if "
@@ -153,7 +141,6 @@ public class FsStateChangelogOptions {
ConfigOptions.key("state.changelog.dstl.dfs.upload.next-attempt-delay")
.durationType()
.defaultValue(Duration.ofMillis(500))
- .withDeprecatedKeys("dstl.dfs.upload.next-attempt-delay")
.withDescription(
"Delay before the next attempt (if the failure was
not caused by a timeout).");
@@ -161,7 +148,6 @@ public class FsStateChangelogOptions {
ConfigOptions.key("state.changelog.dstl.dfs.download.local-cache.idle-timeout-ms")
.durationType()
.defaultValue(Duration.ofMinutes(10))
-
.withDeprecatedKeys("dstl.dfs.download.local-cache.idle-timeout-ms")
.withDescription(
"Maximum idle time for cache files of distributed
changelog file, "
+ "after which the cache files will be
deleted.");
