flink watermark的原理和實踐

1. Watermark概念 watermark是一種衡量Event Time進展的機制，它是數據自己的一個隱藏屬性。一般基於Event Time的數據，自身都包含一個timestamp.watermark是用於處理亂序事件的，而正確的處理亂序事件，一般用watermark機制結合window來實現。咱們知道，流處理從事件產生，到流經source，再到operator，中間是有一個過程和時間的。雖

>>阅读原文<<