This is an automated email from the ASF dual-hosted git repository. tangyun pushed a commit to branch release-1.19 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 697d2b62a5a070ce074550b8767fbc33859db83d Author: Rui Fan <[email protected]> AuthorDate: Tue Feb 27 13:55:19 2024 +0800 [hotfix] Fix the StateTtlConfig#newBuilder doc from Time to Duration --- .../docs/dev/datastream/fault-tolerance/state.md | 20 ++++++++++---------- .../docs/dev/datastream/fault-tolerance/state.md | 20 ++++++++++---------- 2 files changed, 20 insertions(+), 20 deletions(-) diff --git a/docs/content.zh/docs/dev/datastream/fault-tolerance/state.md b/docs/content.zh/docs/dev/datastream/fault-tolerance/state.md index 80f444b13c5..2635c11f1ec 100644 --- a/docs/content.zh/docs/dev/datastream/fault-tolerance/state.md +++ b/docs/content.zh/docs/dev/datastream/fault-tolerance/state.md @@ -305,7 +305,7 @@ import org.apache.flink.api.common.state.ValueStateDescriptor; import org.apache.flink.api.common.time.Time; StateTtlConfig ttlConfig = StateTtlConfig - .newBuilder(Time.seconds(1)) + .newBuilder(Duration.ofSeconds(1)) .setUpdateType(StateTtlConfig.UpdateType.OnCreateAndWrite) .setStateVisibility(StateTtlConfig.StateVisibility.NeverReturnExpired) .build(); @@ -321,7 +321,7 @@ import org.apache.flink.api.common.state.ValueStateDescriptor import org.apache.flink.api.common.time.Time val ttlConfig = StateTtlConfig - .newBuilder(Time.seconds(1)) + .newBuilder(Duration.ofSeconds(1)) .setUpdateType(StateTtlConfig.UpdateType.OnCreateAndWrite) .setStateVisibility(StateTtlConfig.StateVisibility.NeverReturnExpired) .build @@ -399,7 +399,7 @@ Heap state backend 会额外存储一个包括用户状态以及时间戳的 Jav import org.apache.flink.api.common.state.StateTtlConfig; StateTtlConfig ttlConfig = StateTtlConfig - .newBuilder(Time.seconds(1)) + .newBuilder(Duration.ofSeconds(1)) .disableCleanupInBackground() .build(); ``` @@ -409,7 +409,7 @@ StateTtlConfig ttlConfig = StateTtlConfig import org.apache.flink.api.common.state.StateTtlConfig val ttlConfig = StateTtlConfig - .newBuilder(Time.seconds(1)) + .newBuilder(Duration.ofSeconds(1)) .disableCleanupInBackground .build ``` @@ -441,7 +441,7 @@ import org.apache.flink.api.common.state.StateTtlConfig; import org.apache.flink.api.common.time.Time; StateTtlConfig ttlConfig = StateTtlConfig - .newBuilder(Time.seconds(1)) + .newBuilder(Duration.ofSeconds(1)) .cleanupFullSnapshot() .build(); ``` @@ -452,7 +452,7 @@ import org.apache.flink.api.common.state.StateTtlConfig import org.apache.flink.api.common.time.Time val ttlConfig = StateTtlConfig - .newBuilder(Time.seconds(1)) + .newBuilder(Duration.ofSeconds(1)) .cleanupFullSnapshot .build ``` @@ -487,7 +487,7 @@ ttl_config = StateTtlConfig \ ```java import org.apache.flink.api.common.state.StateTtlConfig; StateTtlConfig ttlConfig = StateTtlConfig - .newBuilder(Time.seconds(1)) + .newBuilder(Duration.ofSeconds(1)) .cleanupIncrementally(10, true) .build(); ``` @@ -496,7 +496,7 @@ import org.apache.flink.api.common.state.StateTtlConfig; ```scala import org.apache.flink.api.common.state.StateTtlConfig val ttlConfig = StateTtlConfig - .newBuilder(Time.seconds(1)) + .newBuilder(Duration.ofSeconds(1)) .cleanupIncrementally(10, true) .build ``` @@ -537,7 +537,7 @@ Flink 提供的 RocksDB 压缩过滤器会在压缩时过滤掉已经过期的 import org.apache.flink.api.common.state.StateTtlConfig; StateTtlConfig ttlConfig = StateTtlConfig - .newBuilder(Time.seconds(1)) + .newBuilder(Duration.ofSeconds(1)) .cleanupInRocksdbCompactFilter(1000, Duration.ofHours(1)) .build(); ``` @@ -547,7 +547,7 @@ StateTtlConfig ttlConfig = StateTtlConfig import org.apache.flink.api.common.state.StateTtlConfig val ttlConfig = StateTtlConfig - .newBuilder(Time.seconds(1)) + .newBuilder(Duration.ofSeconds(1)) .cleanupInRocksdbCompactFilter(1000, Duration.ofHours(1)) .build ``` diff --git a/docs/content/docs/dev/datastream/fault-tolerance/state.md b/docs/content/docs/dev/datastream/fault-tolerance/state.md index 0d5705ee196..233f9bdc01b 100644 --- a/docs/content/docs/dev/datastream/fault-tolerance/state.md +++ b/docs/content/docs/dev/datastream/fault-tolerance/state.md @@ -344,7 +344,7 @@ import org.apache.flink.api.common.state.ValueStateDescriptor; import org.apache.flink.api.common.time.Time; StateTtlConfig ttlConfig = StateTtlConfig - .newBuilder(Time.seconds(1)) + .newBuilder(Duration.ofSeconds(1)) .setUpdateType(StateTtlConfig.UpdateType.OnCreateAndWrite) .setStateVisibility(StateTtlConfig.StateVisibility.NeverReturnExpired) .build(); @@ -360,7 +360,7 @@ import org.apache.flink.api.common.state.ValueStateDescriptor import org.apache.flink.api.common.time.Time val ttlConfig = StateTtlConfig - .newBuilder(Time.seconds(1)) + .newBuilder(Duration.ofSeconds(1)) .setUpdateType(StateTtlConfig.UpdateType.OnCreateAndWrite) .setStateVisibility(StateTtlConfig.StateVisibility.NeverReturnExpired) .build @@ -447,7 +447,7 @@ in the background if supported by the configured state backend. Background clean ```java import org.apache.flink.api.common.state.StateTtlConfig; StateTtlConfig ttlConfig = StateTtlConfig - .newBuilder(Time.seconds(1)) + .newBuilder(Duration.ofSeconds(1)) .disableCleanupInBackground() .build(); ``` @@ -456,7 +456,7 @@ StateTtlConfig ttlConfig = StateTtlConfig ```scala import org.apache.flink.api.common.state.StateTtlConfig val ttlConfig = StateTtlConfig - .newBuilder(Time.seconds(1)) + .newBuilder(Duration.ofSeconds(1)) .disableCleanupInBackground .build ``` @@ -491,7 +491,7 @@ import org.apache.flink.api.common.state.StateTtlConfig; import org.apache.flink.api.common.time.Time; StateTtlConfig ttlConfig = StateTtlConfig - .newBuilder(Time.seconds(1)) + .newBuilder(Duration.ofSeconds(1)) .cleanupFullSnapshot() .build(); ``` @@ -502,7 +502,7 @@ import org.apache.flink.api.common.state.StateTtlConfig import org.apache.flink.api.common.time.Time val ttlConfig = StateTtlConfig - .newBuilder(Time.seconds(1)) + .newBuilder(Duration.ofSeconds(1)) .cleanupFullSnapshot .build ``` @@ -543,7 +543,7 @@ This feature can be configured in `StateTtlConfig`: ```java import org.apache.flink.api.common.state.StateTtlConfig; StateTtlConfig ttlConfig = StateTtlConfig - .newBuilder(Time.seconds(1)) + .newBuilder(Duration.ofSeconds(1)) .cleanupIncrementally(10, true) .build(); ``` @@ -552,7 +552,7 @@ import org.apache.flink.api.common.state.StateTtlConfig; ```scala import org.apache.flink.api.common.state.StateTtlConfig val ttlConfig = StateTtlConfig - .newBuilder(Time.seconds(1)) + .newBuilder(Duration.ofSeconds(1)) .cleanupIncrementally(10, true) .build ``` @@ -600,7 +600,7 @@ This feature can be configured in `StateTtlConfig`: import org.apache.flink.api.common.state.StateTtlConfig; StateTtlConfig ttlConfig = StateTtlConfig - .newBuilder(Time.seconds(1)) + .newBuilder(Duration.ofSeconds(1)) .cleanupInRocksdbCompactFilter(1000, Duration.ofHours(1)) .build(); ``` @@ -610,7 +610,7 @@ StateTtlConfig ttlConfig = StateTtlConfig import org.apache.flink.api.common.state.StateTtlConfig val ttlConfig = StateTtlConfig - .newBuilder(Time.seconds(1)) + .newBuilder(Duration.ofSeconds(1)) .cleanupInRocksdbCompactFilter(1000, Duration.ofHours(1)) .build ```
