Hi, I'm not sure what's the reason behind this. Probably classes are somehow attached to the state and this would explain why you are experiencing this issue. I've asked someone else from the community to chip in, but in the meantime, can not you just prepare a new "version 1" of the job, with just some empty `class B` on the class path? Or if this doesn't work, just copy the whole `class B` from version 2?
Best, Piotrek sob., 27 lut 2021 o 19:10 Alexey Trenikhun <yen...@msn.com> napisał(a): > Hello, > Let's have version 1 of my job uses keyed state with name "a" and type A, > which some Avro generated class. Then I upgrade to version 2, which in > addition uses keyed state "b" and type B (another concrete Avro generated > class), I take savepoint with version 2 and decided to downgrade to version > 1 and start with taken savepoint, can I do it? On one hand, version 1 > doesn't have state "b", but seems Flink still tries to create call > restoreSerializer​ and it tries to read runtimeType (`class B`) which is > not available in version 1 > > Thanks, > Alexey >
