反压也可能是下游IO跟不上造成的啊,严重的话上游确实就不工作了呗
在 2021-06-08 11:11:34,"yidan zhao" <hinobl...@gmail.com> 写道: >正常的反压遇到过很多,也解决过很多。 但我现在这个问题类似的也是很多次了,很奇怪。就是反压到CPU利用率反而成0,就是不工作了。 > >LakeShen <shenleifight...@gmail.com> 于2021年6月8日周二 上午10:37写道: >> >> 你可以先结合你的任务逻辑,以及 Flink Web UI 反压监控,看看到底是什么地方引起反压。 >> 一般 source 反压,是下游的算子一直反压到 source。可以看看那个算子引起 >> >> Best, >> LakeShen >> >> >> yidan zhao <hinobl...@gmail.com> 于2021年6月8日周二 上午10:28写道: >> >> > 该任务有时候正常,偶尔反压。 >> > 最近观察发现,反压时,kafkaSouce节点100%反压到停滞,后续算子什么也收不到,任务整体停滞。 >> > >> > 这类错误遇到过很多次了,目前我生产中flink有个很大问题就是这些稳定性,压力大不是需要时间去追赶,而是压力一大就整体处于停滞状态。 >> >