Hi guys, I have one question about savepoint restoration process. As we know that Flink will restore the state of operators by using their UIDs. In our case, we are upgrading one Flink application and unfortunately all the UIDs will be changed. Is there any method to handle transitioning the savepoint to a new flow graph? Thanks in advance.

You will either a) determine the UID hash of all previous operators and set it manually on each operator in your new application with

setUidHash()

b) rewrite the savepoint with the state-processor-api, reading the states and writing them with a new UID c) start from scratch 🤷

Thanks, I think option B is the best. Option C may produce duplicate data records in our business case.