作者:张俊
整理:张友亮(Apache Flink 社区志愿者)
本文共 4745字,预计阅读时间 15min。
本文根据 Apache Flink 系列直播整理而成,由 Apache Flink Contributor、OPPO 大数据平台研发负责人张俊老师分享。主要内容如下:
- 网络流控的概念与背景
- TCP的流控机制
- Flink TCP-based 反压机制(before V1.5)
- Flink Credit-based 反压机制 (since V1.5)
- 总结与思考
网络流控的概念与背景
为什么需要网络流控
首先我们可以看下这张最精简的网络流控的图,Producer 的吞吐率是 2MB/s,Consumer 是 1MB/s,这个时候我们就会发现在网络通信的时候我们的 Producer 的速度是比 Consumer 要快的,有 1MB/s 的这样的速