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
