On 08/06/2023 16:06, Kurt Ostfeld wrote:
If I understand correctly, the scenario is resuming from multiple checkpoint files or from a savepoint and checkpoint files which may be generated by different versions of Flink
No; it's the same version of Flink, you just didn't do a full migration of the savepoint from the start.
So, load old savepoint -> create an incremental checkpoint (which writes bit new state with Kryo5) -> jobs fails -> try recover job (which now has to read state was written with either Kryo2 or Kryo5).
On 08/06/2023 16:06, Kurt Ostfeld wrote:
This pull-request build supports Java records
We'd have to see but of the top of my head I doubt we want to use Kryo for that, and rather extend our PojoSerializer. At least so far that was the plan.
