Flink watermark

在Flink中支持三种不一样的时间概念：处理时间（processing time）、事件时间（event time）、摄取时间（Ingestion time）。程序员 而水印是衡量event time 进展的一种机制，它一般基于事件时间数据属性产生，水印做为数据流的一部分流动并带有时间戳t，表明该时间点之前的数据都已经到达。网络 watermark主要是用于处理乱序事件。而正确的处理乱序事件，一般

>>阅读原文<<