Hi, Flink does not support auto-scaling, yet. Rescaling operations currently are always manual, i.e take a savepoint of the Flink job, and when restoring from the savepoint, define a new parallelism for the job. As for the metrics to be used for auto-scaling, I can imagine that it would be possible to base this on top of metrics such as TM throughput, backpressure, etc. AFAIK, there also currently isn't any official design or discussion on going for this.
Cheers, Gordon On Mon, Nov 12, 2018 at 5:50 PM Nauroz Khan Nausherwani < nauroz-khan.nausherw...@etu.univ-cotedazur.fr> wrote: > Dear Flink Contributors and users, > > I am a PhD student and I was interested to know, using which matrices, and > when does Flink performs scaling-in or scaling out of resources? I did > search the flink's website where I could only find information about how > dynamic scaling is performed in stateless or stateful operator. It would > be interesting to know which matrices Flink uses, and when actually Flink > triggers auto-scaling. > > Any link or reference paper with required information is appreciated. > > best regards, > Nauroz >
