概述
flink背压处理
- 基本原理
- 重要代码分析
基本原理
流处理框架需要考虑的一个重要问题是协调上下游算子处理速率的问题。比如A->B的一个处理链,B处理速率变慢时,A需要及时作出响应(减慢发送或停发),否则会耗尽内存导致任务崩溃。
那flink是如何处理背压的呢?flink处理反压可以分为两种情况:
- A、
A->B
重要代码分析
未完待续。。。。
最后
以上就是清脆老鼠为你收集整理的flink背压处理-结合源码分析基本原理重要代码分析的全部内容,希望文章能够帮你解决flink背压处理-结合源码分析基本原理重要代码分析所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。
本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
发表评论 取消回复