话不多说，直接上图
背压，归根结底就是为了让实施消费的数据和处理的数据达到动态的平衡，让资源利用率达到最高。当前Task处理数据的速度比较慢，比如每条数据都要进行算法调用之类的，而上游Task处理数据较快，从而导致上游发送端申请不到足够的内存，就会造成背压问题。
flink的背压特性是逐渐反向背压，从下游的算子开始逐渐排查是哪个算子处理数据处理不过来了。
然后上游减缓发送速度。
当fink自动逐级背压处理不过来的时候就需要人为手动来干预了。
最后
以上就是含蓄小猫咪最近收集整理的关于flink的背压机制的全部内容，更多相关flink内容请搜索靠谱客的其他文章。
本图文内容来源于网友提供，作为学习参考使用，或来自网络收集整理，版权属于原作者所有。
发表评论 取消回复