对于一个算子来说，输入流比它的输出流快，所以它的输入缓冲区会阻塞前一个算子的输出线程，把数据传输给这个算子。正确的？
Flink 和 Spark 是否都通过阻塞线程来处理背压？那么它们之间有什么区别呢？
对于数据源来说，它一直在生产数据，如果它的输出线程被阻塞了怎么办？缓冲区会溢出吗？
问问题
3071 次
1 回答
7
https://www.ververica.com/blog/how-flink-handles-backpressure
文章非常详细地解释了背压是如何在 flink 中隐式处理的
于 2017-03-25T13:20:55.657 回答