Thank you for your answers. 

I have one more question. 
The Key Managed state for Keyed stream is per key or per operator?

For example I have a keyed stream that is processed by MyProcessFunction
with parallelism = 3. So I have three instances of MyProcessFuntion. The
process function has a KeyManaged state field (Value/List/Key state).

I will have quite big umber of distinct key values in my stream. 
With this, the each state will be per each key value or function instance or
maybe key group?



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Reply via email to