Re: Re:Re:Flink SQL No Watermark

2020-08-13 文章 Shengkai Fang
hi 那你有没有试过将并行度设置为partition的数量 Zhou Zach 于2020年8月13日 周四下午3:21写道： > > > > Hi forideal, > 我也遇到了No Watermark问题，我也设置了table.exec.source.idle-timeout 参数，如下： > > > val streamExecutionEnv = > StreamExecutionEnvironment.getExecutionEnvironment > >

Re:Re:Flink SQL No Watermark

2020-08-13 文章 forideal
大家好 问题的原因定位到了。 由于无法 debug codegen 生成的代码，即使我拿到线上的数据，开启了debug环境依然无法得到进展。 这个时候，我进行了 disable chain，观察 watermark 的生成情况，看看到底在那个环节没有继续往下传递。（因为多个 op chain 在一起，不能确定到底是那个环节存在问题） 发现在 WatermarkAssigner(rowtime=[event_time], watermark=[(event_ti...）这个 op 中部分 task 为 No