Hi Michael, As Roman pointed out Flink currently doesn’t support the auto-scaling. It’s on our roadmap but it requires quite a bit of preliminary work to happen before.
Piotrek > On 5 Dec 2019, at 15:32, r_khachatryan <khachatryan.ro...@gmail.com> wrote: > > 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/
