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/07/20 07:35:34 UTC

[flink] branch master updated: [hotfic][doc] Fix JavaDoc of chapter ETL. This closes #20077

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 dbe4f473ba9 [hotfic][doc] Fix JavaDoc of chapter ETL. This closes #20077
dbe4f473ba9 is described below

commit dbe4f473ba92cfb29c53fdf6fbb0026211a849b8
Author: nieyingping <sm...@163.com>
AuthorDate: Mon Jun 27 11:30:52 2022 +0800

    [hotfic][doc] Fix JavaDoc of chapter ETL. This closes #20077
    
    Co-authored-by: MartijnVisser <ma...@2symbols.com>
---
 docs/content.zh/docs/learn-flink/etl.md | 2 +-
 docs/content/docs/learn-flink/etl.md    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/docs/content.zh/docs/learn-flink/etl.md b/docs/content.zh/docs/learn-flink/etl.md
index 6b45e8c76e6..30812fd42be 100644
--- a/docs/content.zh/docs/learn-flink/etl.md
+++ b/docs/content.zh/docs/learn-flink/etl.md
@@ -399,7 +399,7 @@ public static class ControlFunction extends RichCoFlatMapFunction<String, String
 
 在 Flink 运行时中,`flatMap1` 和 `flatMap2` 在连接流有新元素到来时被调用 —— 在我们的例子中,`control` 流中的元素会进入 `flatMap1`,`streamOfWords` 中的元素会进入 `flatMap2`。这是由两个流连接的顺序决定的,本例中为 `control.connect(streamOfWords)`。
 
-认识到你没法控制 `flatMap1` 和 `flatMap2` 的调用顺序是很重要的。这两个输入流是相互竞争的关系,Flink 运行时将根据从一个流或另一个流中消费的事件做它要做的。对于需要保证时间和/或顺序的场景,你会发现在 Flink 的管理状态中缓存事件一直到它们能够被处理是必须的。(注意:如果你真的感到绝望,可以使用自定义的算子实现 `InputSelectable` 接口,在两输入算子消费它的输入流时增加一些顺序上的限制。)
+认识到你没法控制 `flatMap1` 和 `flatMap2` 的调用顺序是很重要的。这两个输入流是相互竞争的关系,Flink 运行时将根据从一个流或另一个流中消费的事件做它要做的。对于需要保证时间和/或顺序的场景,你会发现在 Flink 的管理状态中缓存事件一直到它们能够被处理是必须的。(注意:如果你真的迫切需要,可以使用自定义的算子实现 {{< javadoc name="InputSelectable" file="org/apache/flink/streaming/api/operators/InputSelectable.html" >}} 接口,在两输入算子消费它的输入流时增加一些顺序上的限制。)
 
 {{< top >}}
 
diff --git a/docs/content/docs/learn-flink/etl.md b/docs/content/docs/learn-flink/etl.md
index fe04bb541bc..2a969327896 100644
--- a/docs/content/docs/learn-flink/etl.md
+++ b/docs/content/docs/learn-flink/etl.md
@@ -475,7 +475,7 @@ mentioned on the `control` stream, and those words are being filtered out of the
 `flatMap1` and `flatMap2` are called by the Flink runtime with elements from each of the two
 connected streams -- in our case, elements from the `control` stream are passed into `flatMap1`, and elements from `streamOfWords` are passed into `flatMap2`. This was determined by the order in which the two streams are connected with `control.connect(streamOfWords)`. 
 
-It is important to recognize that you have no control over the order in which the `flatMap1` and `flatMap2` callbacks are called. These two input streams are racing against each other, and the Flink runtime will do what it wants to regarding consuming events from one stream or the other. In cases where timing and/or ordering matter, you may find it necessary to buffer events in managed Flink state until your application is ready to process them. (Note: if you are truly desperate, it is p [...]
+It is important to recognize that you have no control over the order in which the `flatMap1` and `flatMap2` callbacks are called. These two input streams are racing against each other, and the Flink runtime will do what it wants to regarding consuming events from one stream or the other. In cases where timing and/or ordering matter, you may find it necessary to buffer events in managed Flink state until your application is ready to process them. (Note: if you are truly desperate, it is p [...]
 
 {{< top >}}