For an operator, the input stream is faster than its output stream, so its input buffer will block the previous operator's output thread that transfers the data to this operator. Right?
Do the Flink and the Spark both handle the backpressure by blocking the thread? So what's the difference between them? For the data source, it is continuously producing the data, what if its output thread is blocked? Would the buffer overflow? -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Apache-Flink-How-does-it-handle-the-backpressure-tp8866.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
