【Flink】Flink的事件时间及watermark水印讲解-附代码实例

Flink支持根据事件时间处理，数据流中的每条数据都须要具备各自的时间戳，表明着数据的产生时间【事件时间】。java 在分布式系统中，数据流的采集一般都是有延迟的，多是网络缘由啊，程序缘由啊什么的。因此当数据到达Flink程序中的时候，问题就来了，这些数据都要进行处理吗？有可能其中一部分数据已经延迟了好几个小时了，这对于实时性较强的业务场景是不能容忍的！git 这时候水印就应运而生了，水印的目的就

>>阅读原文<<