Flink WaterMark（水位线）分布式执行理解

背景         WaterMark (水印) 本质上是一个时间戳。当Flink中的运算符接收到水印时，它明白（假设）它不会看到比该时间戳更早的消息。所以，在“EventTime”中，水印也能够被认为是一种告诉Flink它有多远的一种方式，WaterMark还能够用来实现时间延迟。编程        本文主要涉及水印在单线程和分布式状况下的理解，基础知识和应用请看：Flink watermar

>>阅读原文<<