怎么说的，这个应该不是代码层面的问题，所以感觉贴代码意义不大。 我是想看有没有类似的什么idea，什么情况可能呈现类似现象。 就是直接停滞了，我发现的时候所有算子都非反压，只要source处于反压状态。 然后source到下一个算子直接的records sent和records received数量已经彻底不变（眼看好几分钟也不变）。
HunterXHunter <1356469...@qq.com> 于2021年6月8日周二 上午11:13写道： > > 掐头去尾的提问，完全不知道是什么问题，没法回答你，最好是贴出代码，贴出图片等大家才能帮忙分析 > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/
