A common pitiful when upgrading a Flink application with savepoints is that
no explicit UIDs have been assigned to the operators. You can amend that by
first adding UIDs to the job in 1.9.3 and create a savepoint with UIDs.
Then try upgrading again.
On Fri, Feb 19, 2021 at 9:57 AM Tzu-Li (Gordon)
Hi,
I'm not aware of any breaking changes in the savepoint formats from 1.9.3 to
1.11.3.
Let's first try to rule out any obvious causes of this:
- Were any data types / classes that were used in state changed across the
restores? Remember that keys types are also written as part of state
snapshot