对于一个操作符，输入流比输出流快，因此它的输入缓冲区将阻塞前一个操作符的输出线程，该线程将数据传输给这个操作符。正确的？火石和Spark都是通过阻塞螺纹来处理反压力的吗？那么它们之间有什么区别呢？对于数据源，它正在不断地生成数据，如果它的输出线程被阻塞了怎么办？缓冲区会溢出吗？
vfwfrxfs1#
https://www.ververica.com/blog/how-flink-handles-backpressure文章非常详细地解释了如何在flink中隐式地处理反压力
1条答案
按热度按时间vfwfrxfs1#
https://www.ververica.com/blog/how-flink-handles-backpressure
文章非常详细地解释了如何在flink中隐式地处理反压力