Flink 并行度难题（非1无数据，1程序卡住）
flink吧
全部回复
仅看楼主
level 1
home返回回复 楼主
Flink问题，求助大佬!!!
问题描述如下：
1.从kafka获取数据，设置水位线，开窗，处理，写入数据库
2.设置水位线处并行度非1（大于1），数据可进入窗口，但是聚合后无法进入下游，卡死
3.水位线设置为1，数据可进入窗口，同时可进入下游，但是偶发性会出现程序卡住和丢数据的情况
4.问题代码如下
5.现象为
求大佬帮忙看看，我真的乏术了[泪][泪][泪]
2024年02月04日 09点02分 1
level 1
home返回回复 楼主
[泪][泪][泪]
2024年02月06日 07点02分 2
level 1
-
解决了吗
2024年09月05日 17点09分 3
1