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)