Skip to content

Commit

Permalink
[FLINK-25800][docs] Update incorrect links in the datastream/executio…
Browse files Browse the repository at this point in the history
…n_mode.md pages. This closes apache#18491
  • Loading branch information
RocMarshal authored and MartijnVisser committed Mar 14, 2022
1 parent 5c3bca5 commit c97af45
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 5 deletions.
4 changes: 2 additions & 2 deletions docs/content.zh/docs/dev/datastream/execution_mode.md
Original file line number Diff line number Diff line change
Expand Up @@ -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)

自定义算子应谨慎执行,否则可能会有不恰当的行为。更多细节请参见下面的补充说明。
Expand Down
2 changes: 2 additions & 0 deletions docs/content.zh/docs/dev/datastream/operators/overview.md
Original file line number Diff line number Diff line change
Expand Up @@ -680,6 +680,8 @@ data_stream.broadcast()
{{< /tab >}}
{{< /tabs>}}

<a name="task-chaining-and-resource-groups"></a>

## 算子链和资源组

将两个算子链接在一起能使得它们在同一个线程中执行,从而提升性能。Flink 默认会将能链接的算子尽可能地进行链接(例如, 两个 map 转换操作)。此外, Flink 还提供了对链接更细粒度控制的 API 以满足更多需求:
Expand Down
5 changes: 2 additions & 3 deletions docs/content/docs/dev/datastream/execution_mode.md
Original file line number Diff line number Diff line change
Expand Up @@ -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)

Expand Down

0 comments on commit c97af45

Please sign in to comment.