问题定位:Flink水位线不触发问题

Flink水位线不触发问题 窗口计算时遇到好几回水位线不触发的状况,简单总结下。html 首先,介绍下Flink的事件时间(EventTime)和水位线(Watermarks)的概念。java 1、处理时间 若是要构造一个实时的流式应用,或早或晚都会接触到EventTime这个概念。现实场景中也会遇到消息乱序到达,这里会介绍到为何须要事件时间和如何去处理乱序到达的数据。 ProcessingTim
相关文章
相关标签/搜索