Flink 并行流中 watermark 机制无法触发窗口计算的原因分析
Kafka Source 接收并处理来自 Kafka 的点击数据(指定事件时间)，开一个滚动窗口(Tumble Windows) 每 10 秒统计一次 pv 并将结果输出到 Print Sink 中...
排序
Apache Flink 漫谈系列 - Watermark是个啥？
在介绍Watermark相关内容之前我们先抛出一个具体的问题，在实际的流式计算中数据到来的顺序对计算结果的正确性有至关重要的影响，比如：某数据源中的某些数据由于某种原因(如：网络原因，外部存储自身原因...