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 th
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 KeyMa
Hi Kristoff,
case 1:
first of all Flink groups keys internally into so-called "key groups"
for reducing the management overhead. The maximum parallelism decides
about the number of key groups. When performing a rescale, the key
groups are basically distributed using some consistent hashing al
