开发者社区> 问答> 正文

请问,对一个DataStream重复声明watermark,前面的watermark会被覆盖掉吗?

请问,对一个DataStream重复声明watermark,前面的watermark会被覆盖掉吗? 比如我再source端声明了watermark,进行了一系列操作后,我觉得watermark的延迟不满足需求,就再次声明一次。 另外,稍微咨询下另外一个问题,两个流join之后,watermark会消失吗?看书上说的是,以两个流最小的watermark(全局最小)为准。 主要是在阿里云Blink上,使用sql进行join后,说的是时间属性字段会消失。有点不明白。*来自志愿者整理的FLINK邮件归档

展开
收起
玛丽莲梦嘉 2021-12-03 18:37:30 1371 0
1 条回答
写回答
取消 提交回答
    1. 以我的理解, 再次下发watermark会覆盖之前的, 所以在经过n个operator后,可以用再次声明watermark的方式来调整.
    2. 如果是DataStream模式下, 两个流join后, 下游收到的watermark是较小的流的watermark, 如果是stream模式下的sql window join, 那么下游收到的 watermark是较小一侧表的watermark - sql设定的时间窗口.*来自志愿者整理的FLINK邮件归档
    2021-12-03 18:59:09
    赞同 展开评论 打赏
问答分类:
问答地址:
问答排行榜
最热
最新

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载