flink水印

1 kafka數據源，設置水印，一般直接在數據源消費者上加載。 如下：     2 水印併發度設置 2.1 對於kafka數據源。   我們設置併發度一般設置topic對應的分區數。如果分區數爲2，則爲2。 如果設置爲4， 實際上即時啓動了4個task，也只有2個真正消費數據併產生水印。另外2個task一致在等待，不會發出水印。 如下圖，爲分區爲2，設置併發度爲4的情況，可以看到上面2個子任務根本

>>阅读原文<<