klion26 commented on a change in pull request #12237: URL: https://github.com/apache/flink/pull/12237#discussion_r454812043
########## File path: docs/learn-flink/streaming_analytics.zh.md ########## @@ -355,18 +306,15 @@ private static class MyWindowFunction extends ProcessWindowFunction< } {% endhighlight %} -Notice that the `Iterable<SensorReading>` -will contain exactly one reading -- the pre-aggregated maximum computed by `MyReducingMax`. +请注意 `Iterable<SensorReading>`将只包含一个读数 -- `MyReducingMax` 计算出的预先汇总的最大值。 -### Late Events +<a name="Late-Events"></a> +### 晚到的事件 -By default, when using event time windows, late events are dropped. There are two optional parts of -the window API that give you more control over this. +默认场景下,超过最大无序边界的事件会被删除,但是 Flink 给了我们两个选择去控制这些事件。 + +您可以使用一种称为[旁路输出]({% link learn-flink/event_driven.zh.md %}#side-outputs) 的机制来安排将要删除的事件收集到侧输出流中,这里是一个示例: Review comment: @twentyworld 我看到你提的 issue 了,对于这个修改可以不创建 issue 直接提交 hotfix 的 PR 就行(因为比较小) ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org