Hi Dominik, Do you mean how Flink redistributes an operator’s state when the parallelism of the operator is changed? If so, you can take a look at [1] and [2].
Cheers, Gordon [1] https://issues.apache.org/jira/browse/FLINK-3755 [2] https://docs.google.com/document/d/1G1OS1z3xEBOrYD4wSu-LuBCyPUWyFd9l3T9WyssQ63w/edit# On December 8, 2016 at 4:40:18 AM, Dominik Safaric (dominiksafa...@gmail.com) wrote: Hi everyone, In the case of scaling out a Flink cluster, how does Flink handle operator state partitioning of a staged topology? Regards, Dominik
