Hi Michael Flink *does* detect backpressure but currently, it only propagates it back to sources. And so it doesn't support auto-scaling.
Regards, Roman Nguyen, Michael wrote > How does Flink handle backpressure (caused by an increase in traffic) in a > Flink job when it’s being hosted in an EMR cluster? Does Flink detect the > backpressure and auto-scales the EMR cluster to handle the workload to > relieve the backpressure? Once the backpressure is gone, then the EMR > cluster would scale back down? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
