Hi Jean-Marc, We've just added this as SQL feature [1]. It's possible to use SavepointLoader from java but it's more complicated. For the SQL story there is no 1.x backport...
[1] https://nightlies.apache.org/flink/flink-docs-master/docs/libs/state_processor_api/#metadata BR, G On Fri, Apr 11, 2025 at 12:40 PM Jean-Marc Paulin <jm.pau...@gmail.com> wrote: > Hi there, > > I've got this odd issue with our Flink 1.20 application. We had to make a > change to our savepoints structure (essentially we need to change the keys > we used in the keyBy) so we wrote an application to migrate the savepoint > from the oldkey to the new key. > > However when I run the migrated application I get a lot of errors such as: > > Failed to rollback to checkpoint/savepoint > file:/tmp/savepoint-22f53d5c-764f-4e50-88cc-090ba82f8c9f. Cannot map > checkpoint/savepoint state for operator b7034a3a871df55ba4407d4f859fa00b to > the new program, because the operator is not available in the new program. > > I understand that means there is an operator in our savepoint that is not > in the application, but I cannot think of any new one that would > have changed. > > Is there an API to list all the operators that are in the savepoints? > Maybe that would help me to identify the culprit. > > Thanks > > JM >
