Apache Flink:如何处理背压?

jie*_*cxy 2 backpressure apache-flink

对于操作员,输入流比其输出流快,因此其输入缓冲区将阻塞前一个操作员的输出线程,该线程将数据传输到该操作员。对?

Flink和Spark是否都通过阻塞线程来处理背压?那么它们之间有什么区别?

对于数据源,它会持续生成数据,如果其输出线程被阻塞怎么办?缓冲区会溢出吗?

小智 6

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

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