apache-flink - Apache 弗林克 : How does it handle the backpressure?

Question

对于一个运算符，输入流比其输出流快，因此其输入缓冲区将阻塞前一个运算符的输出线程，该输出线程将数据传输到该运算符。对吗？

Flink和Spark都是通过阻塞线程来处理背压的吗？那么它们有什么区别呢？

对于数据源来说，它是不断产生数据的，如果它的输出线程被阻塞了怎么办？缓冲区会溢出吗？

Answer 1

https://www.ververica.com/blog/how-flink-handles-backpressure

本文详细解释了 flink 中如何隐式处理背压