flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Congxian Qiu <qcx978132...@gmail.com>
Subject Re: Questions regarding Key Managed state
Date Sat, 04 Apr 2020 01:07:47 GMT

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.


KristoffSC <krzysiek.chmielewski@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/

View raw message