如果算子之间的分区规则是forward，则watermark也采取forward的方式传播。
如果算子之间的分区规则是hash，则采用广播的方式传播，其他的重新分区的算子应该也类似。
在watermark广播的策略下，下游所有的事件时钟都会相等。
标签：watermark,分区,Flink,水印,传播,算子,forward From： https://www.cnblogs.com/averyve/p/16852944.html
如果算子之间的分区规则是forward，则watermark也采取forward的方式传播。
如果算子之间的分区规则是hash，则采用广播的方式传播，其他的重新分区的算子应该也类似。
在watermark广播的策略下，下游所有的事件时钟都会相等。
标签：watermark,分区,Flink,水印,传播,算子,forward From： https://www.cnblogs.com/averyve/p/16852944.html