hi, 你的意思是没有办法在codegen出来的代码上加断点的意思吗？
这里倒是有一个比较hack的方法：
将生成的类放在一个java文件之中，然后修改改下GeneratedClass下的newInstance方法，如果classname ==
“WatermarkGenerator$2” 则将刚才的类则返回 new WatermarkGenerator$2 这个类。
我个人对于问题的猜测是有一条数据的rowtime远远晚于其他数据，从而将整体的watermark提得很高，导致后面的“晚到”的数据一直无法触发watermark的生成。
forideal 于2020年8月13日周四
大家好，请教一个问题
我有一条进行 session window 的 sql。这条 sql 消费较少数据量的 topic 的时候，是可以生成
watermark。消费大量的数据的时候，就无法生成watermark。
一直是No Watermark。 暂时找不到排查问题的思路。
Flink 版本号是 1.10，kafka 中消息是有时间的，其他的任务是可以拿到这个时间生成watermark。同时设置了
EventTime mode 模式，Blink Planner。
|
No Watermark |
