Flink系列：事件Time时间乱序到达处理方法

  到达时间无序 kafka的数据，不一定按照时间产生的时间到达flink，为了解决这个问题，需要引入Watermark   时间到达的3中情况 顺序到达 乱序到达   并发到达   Watermark 如果指定多个Watermark，后面的将覆盖前面的。 两种方法   基于时间周期（推荐） 周期性（默认100ms）生成和发送Watermark，定义一个最大允许乱序时间。   基于特定事件 如果发

>>阅读原文<<