flink水印

1 kafka数据源，设置水印，一般直接在数据源消费者上加载。 如下：     2 水印并发度设置 2.1 对于kafka数据源。   我们设置并发度一般设置topic对应的分区数。如果分区数为2，则为2。 如果设置为4， 实际上即时启动了4个task，也只有2个真正消费数据并产生水印。另外2个task一致在等待，不会发出水印。 如下图，为分区为2，设置并发度为4的情况，可以看到上面2个子任务根本

>>阅读原文<<