云星数据---Apache Flink实战系列(精品版)】:Flink其他操作及内容004-flink的背压机制002

flink背压的两种场景 1.本地传输 如果task1和task2都运行在同一个工作节点(TaskManager),缓冲区可以被直接共享给下一个task,一旦task 2消费了数据它会 被回收。如果task 2比task 1慢,buffer会以比task 1填充的速度更慢的速度进行回收从而迫使task 1降速。 2.网络传输 如果task 1和task 2运行在不同的工作节点上。一旦缓冲区内的数据
相关文章
相关标签/搜索