Hi BenChen, 1. 可以保证需要 watermark 算子之前的算子和前面的算子不是 Forward 。 2. 如果是自己实现的 Connector 的话,可能定时检测调用 SourceFunction#markAsTemporarilyIdle 来标记为 idle,我看目前 Kafka 是刚启动时候进行检测。 Best, Hailong Wang 在 2020-10-28 17:54:22,"BenChen" <haibin...@163.com> 写道: >Hi >all,在Flink1.11里面新增了WatermarkStetagy来处理某个并行度下没有数据导致watermark不触发的问题,在1.10里面Flink有什么机制解决这个问题吗?谢谢 > > >| | >BenChen >| >| >haibin...@163.com >| >签名由网易邮箱大师定制 >
- 关于并行下watermark不生成 BenChen
- Re:关于并行下watermark不生成 Shubin Ruan
- Re: 关于并行下watermark不生成 zhisheng
- Re:关于并行下watermark不生成 hailongwang