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/