开发者社区 问答 正文

关于并行下watermark不生成,如何解决?

Hi all,在Flink1.11里面新增了WatermarkStetagy来处理某个并行度下没有数据导致watermark不触发的问题,在1.10里面Flink有什么机制解决这个问题吗?谢谢*来自志愿者整理的flink

展开
收起
毛毛虫雨 2021-12-05 21:37:07 748 分享 版权
1 条回答
写回答
取消 提交回答
  • 可以考虑在数据源处进行处理: 设置个时间阈值,若检测到某个 key 下的数据超过时间阈值还未更新,则根据系统的 processing time 按照某种逻辑生成1条水印发送到下游。*来自志愿者整理的flink

    2021-12-05 22:28:15
    赞同 展开评论
问答地址: