flink watermark的原理和实践

1. Watermark概念 watermark是一种衡量Event Time进展的机制，它是数据自己的一个隐藏属性。一般基于Event Time的数据，自身都包含一个timestamp.watermark是用于处理乱序事件的，而正确的处理乱序事件，一般用watermark机制结合window来实现。咱们知道，流处理从事件产生，到流经source，再到operator，中间是有一个过程和时间的。虽

>>阅读原文<<