flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tzu-Li (Gordon) Tai" <tzuli...@apache.org>
Subject Re: Partitioning operator state
Date Thu, 08 Dec 2016 07:00:00 GMT
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 (dominiksafaric@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  


Mime
View raw message