(flink) branch master updated: [hotfix][docs] Typos and format in `state.md` and `state_v2.md`

[snuyanzin]

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 <jackeyzh...@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 <jackeyzh...@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) {