欣慰乌龟

文章
7
资源
0
加入时间
3年0月27天

Flink不触发窗口计算又不报错的问题定位

刚接触Flink不久,照着之前的一个老项目重构。好不容易写完代码并解决完各种报错,结果发现即使不报错也无法运出自己想要的效果。调试发现能正常消费到Kafka的消息,但是却无法触发窗口计算。在网上翻到一篇博客问题定位:Flink水位线不触发问题 ,上面说是watermark有问题,通过Flink的管理控制台发现watermark没生成:注意,截图的时候我的问题已经解决了,没有watermark的时...