文章目录
- 1.概述
- 2.小结
![](https://img.laitimes.com/img/__Qf2AjLwojIjJCLyojI0JCLicWZwpmLhZWN3MmYiBTOmJmN4UmZhZjZxQTYhJ2MyMjM1ITN2IzLc52YucWbp5GZzNmLn9Gbi1yZtl2Lc9CX6MHc0RHaiojIsJye.jpeg)
1.概述
在 Flink UI: Flink 1.10 如何查看 数据源 的背压(反压)情况(消费kafka) 中我们学会了如何查看反压。
在 【Flink】Flink反压(背压)网络流控 这里我们对反压有了一个整体的认识。
在这篇文章中,我们一直没有去研究代码,只是理论上知道了,如果在反压的时候多次执行jstack可能得到如下异常栈
为了判断是否进行反压,jobmanager会每50ms触发100次stack traces。
offline_data_source (42/48)" #