之前遇到过在sink到kudu的时候出现反压很严重,主要原因是测试数据不当的问题,根据我的经验,比较多的是下游io瓶颈,可以到sink组件的日志查看问题





------------------ 原始邮件 ------------------
发件人: yidan zhao <hinobl...@gmail.com&gt;
发送时间: 2021年6月8日 11:18
收件人: user-zh <user-zh@flink.apache.org&gt;
主题: 回复:【问题分析】Fink任务无限反压



怎么说的,这个应该不是代码层面的问题,所以感觉贴代码意义不大。
我是想看有没有类似的什么idea,什么情况可能呈现类似现象。 就是直接停滞了,我发现的时候所有算子都非反压,只要source处于反压状态。
然后source到下一个算子直接的records sent和records received数量已经彻底不变(眼看好几分钟也不变)。

HunterXHunter <1356469...@qq.com&gt; 于2021年6月8日周二 上午11:13写道:
&gt;
&gt; 掐头去尾的提问,完全不知道是什么问题,没法回答你,最好是贴出代码,贴出图片等大家才能帮忙分析
&gt;
&gt;
&gt;
&gt; --
&gt; Sent from: http://apache-flink.147419.n8.nabble.com/

回复