You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sn...@apache.org on 2025/08/15 20:19:33 UTC
(flink) branch master updated: [hotfix][docs] Typos and format in `state.md` and `state_v2.md`
This is an automated email from the ASF dual-hosted git repository.
snuyanzin 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 e8a3305a61b [hotfix][docs] Typos and format in `state.md` and `state_v2.md`
e8a3305a61b is described below
commit e8a3305a61bdab03fd1a9b484d093f8402cf61fa
Author: Jackeyzhe <ja...@163.com>
AuthorDate: Sat Aug 16 04:19:26 2025 +0800
[hotfix][docs] Typos and format in `state.md` and `state_v2.md`
Co-authored-by: jackeyzhe <ja...@gmail.com>
---
docs/content.zh/docs/dev/datastream/fault-tolerance/state.md | 4 ++--
docs/content.zh/docs/dev/datastream/fault-tolerance/state_v2.md | 2 +-
docs/content/docs/dev/datastream/fault-tolerance/state.md | 2 +-
docs/content/docs/dev/datastream/fault-tolerance/state_v2.md | 2 +-
4 files changed, 5 insertions(+), 5 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 335483631c6..dd358a9a0b1 100644
--- a/docs/content.zh/docs/dev/datastream/fault-tolerance/state.md
+++ b/docs/content.zh/docs/dev/datastream/fault-tolerance/state.md
@@ -320,7 +320,7 @@ ttl_config = StateTtlConfig \
可以按照如下所示配置更细粒度的后台清理策略。当前的实现中 `HeapStateBackend` 依赖增量数据清理，`RocksDBStateBackend` 利用压缩过滤器进行后台清理。
-#### 全量快照时进行清理
+##### 全量快照时进行清理
另外，你可以启用全量快照时进行清理的策略，这可以减少整个快照的大小。当前实现中不会清理本地的状态，但从上次快照恢复时，不会恢复那些已经删除的过期数据。
该策略可以通过 `StateTtlConfig` 配置进行配置：
@@ -520,7 +520,7 @@ public class BufferingSink
}
@Override
- public void invoke(Tuple2<String, Integer> value, Context contex) throws Exception {
+ public void invoke(Tuple2<String, Integer> value, Context context) throws Exception {
bufferedElements.add(value);
if (bufferedElements.size() >= threshold) {
for (Tuple2<String, Integer> element: bufferedElements) {
diff --git a/docs/content.zh/docs/dev/datastream/fault-tolerance/state_v2.md b/docs/content.zh/docs/dev/datastream/fault-tolerance/state_v2.md
index 79a744b90f8..d3cde17b75d 100644
--- a/docs/content.zh/docs/dev/datastream/fault-tolerance/state_v2.md
+++ b/docs/content.zh/docs/dev/datastream/fault-tolerance/state_v2.md
@@ -578,7 +578,7 @@ public class BufferingSink
}
@Override
- public void invoke(Tuple2<String, Integer> value, Context contex) throws Exception {
+ public void invoke(Tuple2<String, Integer> value, Context context) throws Exception {
bufferedElements.add(value);
if (bufferedElements.size() >= threshold) {
for (Tuple2<String, Integer> element: bufferedElements) {
diff --git a/docs/content/docs/dev/datastream/fault-tolerance/state.md b/docs/content/docs/dev/datastream/fault-tolerance/state.md
index eced3a909b7..1eb5b1f2920 100644
--- a/docs/content/docs/dev/datastream/fault-tolerance/state.md
+++ b/docs/content/docs/dev/datastream/fault-tolerance/state.md
@@ -639,7 +639,7 @@ public class BufferingSink
}
@Override
- public void invoke(Tuple2<String, Integer> value, Context contex) throws Exception {
+ public void invoke(Tuple2<String, Integer> value, Context context) throws Exception {
bufferedElements.add(value);
if (bufferedElements.size() >= threshold) {
for (Tuple2<String, Integer> element: bufferedElements) {
diff --git a/docs/content/docs/dev/datastream/fault-tolerance/state_v2.md b/docs/content/docs/dev/datastream/fault-tolerance/state_v2.md
index 5f82e336f34..cc3da7ee231 100644
--- a/docs/content/docs/dev/datastream/fault-tolerance/state_v2.md
+++ b/docs/content/docs/dev/datastream/fault-tolerance/state_v2.md
@@ -579,7 +579,7 @@ public class BufferingSink
}
@Override
- public void invoke(Tuple2<String, Integer> value, Context contex) throws Exception {
+ public void invoke(Tuple2<String, Integer> value, Context context) throws Exception {
bufferedElements.add(value);
if (bufferedElements.size() >= threshold) {
for (Tuple2<String, Integer> element: bufferedElements) {