flink watermark 合并策略机制

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

flink watermark 合并策略机制

张锴
flink 版本1.12.2,在看官方文档介绍watermark时,看到一句话
*标题是:单调递增时间戳分配器*
注意:在 Flink 应用程序中,如果是并行数据源,则只要求并行数据源中的每个*单分区数据源任务*时间戳递增。例如,设置每一个并行数据源实例都只读取一个
Kafka 分区,则时间戳只需在每个 Kafka 分区内递增即可。Flink 的 watermark
合并机制会在并行数据流进行分发(shuffle)、联合(union)、连接(connect)或合并(merge)时生成正确的 watermark。

请问一下报红的部分在官方文档哪里描述了,我没有找到,有人能给指一下吗?