flink背压处理
- 基本原理
- 重要代码分析
基本原理
流处理框架需要考虑的一个重要问题是协调上下游算子处理速率的问题。比如A->B的一个处理链,B处理速率变慢时,A需要及时作出响应(减慢发送或停发),否则会耗尽内存导致任务崩溃。
那flink是如何处理背压的呢?flink处理反压可以分为两种情况:
- A、
A->B
重要代码分析
未完待续。。。。
最后
以上就是清脆老鼠最近收集整理的关于flink背压处理-结合源码分析基本原理重要代码分析的全部内容,更多相关flink背压处理-结合源码分析基本原理重要代码分析内容请搜索靠谱客的其他文章。
本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
发表评论 取消回复