RE: [External] Terrible bug related to serialization of Pojos in keystate.

2024-10-16 Thread Schwalbe Matthias
Hi Ammon Diether, This is actually not a bug, for logical (and documented) reasons keys can not be schema-migrated: * When storing state / hash-distributing events, the target key group (one out of max parallelism) is calculated from the key hash. * If you change the key, the hash chang

Terrible bug related to serialization of Pojos in keystate.

2024-10-16 Thread Ammon Diether
We have encountered a rather rare, but very nasty bug with Flink related to serialization of Pojos in keystate. -- Timeline -- 1) Write a specific item to keystate of class C at Time1, no read of that key will happen until step 5. 2) Time elapses 3) class C is schema evolved to include an additio