开发者社区> 问答> 正文

关于Watermark的使用调试问题

想问下社区,watermark必须加在数据源上吗?顺便想问下一般用什么方式来调watermark,我自己本地有发现加在map

function之后,watermark会自动重置为默认值的情况。

谢谢!*来自志愿者整理的flink邮件归档

展开
收起
EXCEED 2021-12-01 17:40:46 985 0
1 条回答
写回答
取消 提交回答
  • 可以中途产生,走这个接口

    org.apache.flink.streaming.api.datastream.DataStream#assignTimestampsAndWatermarks(org.apache.flink.api.common.eventtime.WatermarkStrategy )

    麻烦贴一下你加 watermark 的代码和 pipeline 看一下啥情况*来自志愿者整理的flink邮件归档

    2021-12-01 17:41:24
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

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