You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ma...@apache.org on 2022/03/14 21:56:11 UTC

[flink] branch master updated: [FLINK-25800][docs] Update incorrect links in the datastream/execution_mode.md pages. This closes #18491

This is an automated email from the ASF dual-hosted git repository.

martijnvisser 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 c97af45  [FLINK-25800][docs] Update incorrect links in the datastream/execution_mode.md pages. This closes #18491
c97af45 is described below

commit c97af456bffb04279bc16d02d45b297713533287
Author: Roc Marshal <fl...@126.com>
AuthorDate: Tue Jan 25 12:59:17 2022 +0800

    [FLINK-25800][docs] Update incorrect links in the datastream/execution_mode.md pages. This closes #18491
---
 docs/content.zh/docs/dev/datastream/execution_mode.md     | 4 ++--
 docs/content.zh/docs/dev/datastream/operators/overview.md | 2 ++
 docs/content/docs/dev/datastream/execution_mode.md        | 5 ++---
 3 files changed, 6 insertions(+), 5 deletions(-)

diff --git a/docs/content.zh/docs/dev/datastream/execution_mode.md b/docs/content.zh/docs/dev/datastream/execution_mode.md
index e0655b7..2cf146a 100644
--- a/docs/content.zh/docs/dev/datastream/execution_mode.md
+++ b/docs/content.zh/docs/dev/datastream/execution_mode.md
@@ -201,11 +201,11 @@ Checkpointing 用于故障恢复的特点之一是,在发生故障时,Flink
 
 `批`模式下的行为变化:
 
-* “滚动"操作,如 [reduce()]({{< ref "docs/dev/datastream/operators/overview" >}}#reduce) 或 [sum()]({{< ref "docs/dev/datastream/operators/overview" >}}#aggregations),会对`流`模式下每一条新记录发出增量更新。在`批`模式下,这些操作不是"滚动”。它们只发出最终结果。
+* “滚动"操作,如 [reduce()]({{< ref "docs/dev/datastream/operators/overview" >}}#reduce) 或 sum(),会对`流`模式下每一条新记录发出增量更新。在`批`模式下,这些操作不是"滚动”。它们只发出最终结果。
 
 `批`模式下不支持的:
 
-* [Checkpointing]({{< ref "docs/concepts/stateful-stream-processing" >}}#stateful-stream-processing) 和任何依赖于 checkpointing 的操作都不支持。
+* [Checkpointing]({{< ref "docs/concepts/stateful-stream-processing" >}}#checkpointing) 和任何依赖于 checkpointing 的操作都不支持。
 * [迭代(Iterations)]({{< ref "docs/dev/datastream/operators/overview" >}}#iterate)
 
 自定义算子应谨慎执行,否则可能会有不恰当的行为。更多细节请参见下面的补充说明。
diff --git a/docs/content.zh/docs/dev/datastream/operators/overview.md b/docs/content.zh/docs/dev/datastream/operators/overview.md
index 223839b..3c62266 100644
--- a/docs/content.zh/docs/dev/datastream/operators/overview.md
+++ b/docs/content.zh/docs/dev/datastream/operators/overview.md
@@ -680,6 +680,8 @@ data_stream.broadcast()
 {{< /tab >}}
 {{< /tabs>}}
 
+<a name="task-chaining-and-resource-groups"></a>
+
 ## 算子链和资源组
 
 将两个算子链接在一起能使得它们在同一个线程中执行,从而提升性能。Flink 默认会将能链接的算子尽可能地进行链接(例如, 两个 map 转换操作)。此外, Flink 还提供了对链接更细粒度控制的 API 以满足更多需求:
diff --git a/docs/content/docs/dev/datastream/execution_mode.md b/docs/content/docs/dev/datastream/execution_mode.md
index 7837558..415a82d 100644
--- a/docs/content/docs/dev/datastream/execution_mode.md
+++ b/docs/content/docs/dev/datastream/execution_mode.md
@@ -343,15 +343,14 @@ others are not supported.
 Behavior Change in BATCH mode:
 
 * "Rolling" operations such as [reduce()]({{< ref "docs/dev/datastream/operators/overview" >}}#reduce) 
-  or [sum()]({{< ref "docs/dev/datastream/operators/overview" >}}#aggregations)
-  emit an incremental update for every new record that arrives in `STREAMING`
+  or sum() emit an incremental update for every new record that arrives in `STREAMING`
   mode. In `BATCH` mode, these operations are not "rolling". They emit only the
   final result.
 
 
 Unsupported in BATCH mode:
 
-* [Checkpointing]({{< ref "docs/concepts/stateful-stream-processing" >}}#stateful-stream-processing) 
+* [Checkpointing]({{< ref "docs/concepts/stateful-stream-processing" >}}#checkpointing) 
   and any operations that depend on checkpointing do not work.
 * [Iterations]({{< ref "docs/dev/datastream/operators/overview" >}}#iterate)