Hi Many keys can be in a single state(each state can have multiple key-group, and keys will be assigned to the right key-group)
If you write a custom process function that uses a state you created, then there is only one user state in that instance(do not count the underlying state of Flink if there has any), all the keys go into this instance will use this user state. Best, Congxian KristoffSC <krzysiek.chmielew...@gmail.com> 于2020年4月3日周五 下午11:27写道： > 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/ >
