请问，对一个DataStream重复声明watermark，前面的watermark会被覆盖掉吗？
请问，对一个DataStream重复声明watermark，前面的watermark会被覆盖掉吗？ 比如我再source端声明了watermark，进行了一系列操作后，我觉得watermark的延迟不满足需求，就再次声明一次。 另外，稍微咨询下另外一个问题，两个流join之后，watermark会消失吗？看书上说的是，以两个流最小的watermark（全局最小）为准。 主要是在阿里云Blink上，使用sql进行join后，说的是时间属性字段会消失。有点不明白。*来自志愿者整理的FLINK邮件归档
展开
收起
1
条回答
写回答
写回答
-
- 以我的理解, 再次下发watermark会覆盖之前的, 所以在经过n个operator后，可以用再次声明watermark的方式来调整.
- 如果是DataStream模式下, 两个流join后, 下游收到的watermark是较小的流的watermark, 如果是stream模式下的sql window join, 那么下游收到的 watermark是较小一侧表的watermark - sql设定的时间窗口.*来自志愿者整理的FLINK邮件归档
2021-12-03 18:59:09赞同 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
问答排行榜
最热
最新
推荐问答
