This is an automated email from the ASF dual-hosted git repository.
tangyun 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 aa2dddc [FLINK-24106][docs] Remove notice that pyflink does not
support state TTL
aa2dddc is described below
commit aa2dddcf1cf9fb6241c4840f9c907530b76dc02a
Author: Yun Tang <[email protected]>
AuthorDate: Wed Sep 1 21:03:06 2021 +0800
[FLINK-24106][docs] Remove notice that pyflink does not support state TTL
---
docs/content.zh/docs/dev/datastream/fault-tolerance/state.md | 2 --
docs/content/docs/dev/datastream/fault-tolerance/state.md | 2 --
2 files changed, 4 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 5b45613..87bd7fe 100644
--- a/docs/content.zh/docs/dev/datastream/fault-tolerance/state.md
+++ b/docs/content.zh/docs/dev/datastream/fault-tolerance/state.md
@@ -390,8 +390,6 @@ Heap state backend 会额外存储一个包括用户状态以及时间戳的 Jav
- 当前开启 TTL 的 map state 仅在用户值序列化器支持 null 的情况下，才支持用户值为 null。如果用户值序列化器不支持 null，
可以用 `NullableSerializer` 包装一层。
-- State TTL 当前在 PyFlink DataStream API 中还不支持。
-
#### 过期数据的清理
默认情况下，过期数据会在读取的时候被删除，例如 `ValueState#value`，同时会有后台线程定期清理（如果 StateBackend
支持的话）。可以通过 `StateTtlConfig` 配置关闭后台清理：
diff --git a/docs/content/docs/dev/datastream/fault-tolerance/state.md
b/docs/content/docs/dev/datastream/fault-tolerance/state.md
index 0137a6e..bd4b84b 100644
--- a/docs/content/docs/dev/datastream/fault-tolerance/state.md
+++ b/docs/content/docs/dev/datastream/fault-tolerance/state.md
@@ -426,8 +426,6 @@ will lead to compatibility failure and
`StateMigrationException`.
- The map state with TTL currently supports null user values only if the user
value serializer can handle null values.
If the serializer does not support null values, it can be wrapped with
`NullableSerializer` at the cost of an extra byte in the serialized form.
-- State TTL is still not supported in PyFlink DataStream API.
-
#### Cleanup of Expired State
By default, expired values are explicitly removed on read, such as
`ValueState#value`, and periodically garbage collected
