孙金城flink视频笔记-flink优势特点

1.流计算乱序问题 无限流count不会有乱序问题，分组统计才会有乱序问题 watermark是一个时间戳，标识了小于这个时间戳的事件都已经到达了 watermark水印在源位置发射，通过拓扑中的运算符传播 watermark也是streamElement 和普通数据一起在算子之间传递（可以看成一条数据） watermak出发窗口计算，那么long.Max_value值会在公诉算子后续没有任何数据

>>阅读原文<<