Flink水印的传播规律
如果算子之间的分区规则是forward，则watermark也采取forward的方式传播。
如果算子之间的分区规则是hash，则采用广播的方式传播，其他的重新分区的算子应该也类似。
在watermark广播的策略下，下游所有的事件时钟都会相等。
原文地址：http://www.cnblogs.com/averyve/p/16852944.html
声明：本站所有文章，如无特殊说明或标注，均为本站原创发布。任何个人或组织，在未征得本站同意时，禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益，可联系我们进行处理。
