之前遇到过在sink到kudu的时候出现反压很严重,主要原因是测试数据不当的问题,根据我的经验,比较多的是下游io瓶颈,可以到sink组件的日志查看问题
------------------ 原始邮件 ------------------ 发件人: yidan zhao <hinobl...@gmail.com> 发送时间: 2021年6月8日 11:18 收件人: user-zh <user-zh@flink.apache.org> 主题: 回复:【问题分析】Fink任务无限反压 怎么说的,这个应该不是代码层面的问题,所以感觉贴代码意义不大。 我是想看有没有类似的什么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/