FlinkFLink 反压 源码分析-flink如何实现反压的

Posted 2023-03-05 九师兄

文章目录

• 1.概述
• 2.小结

1.概述

在 Flink UI: Flink 1.10 如何查看 数据源 的背压（反压）情况（消费kafka） 中我们学会了如何查看反压。

在 【Flink】Flink反压（背压）网络流控 这里我们对反压有了一个整体的认识。

在这篇文章中，我们一直没有去研究代码，只是理论上知道了，如果在反压的时候多次执行jstack可能得到如下异常栈

为了判断是否进行反压，jobmanager会每50ms触发100次stack traces。

offline_data_source (42/48)" #