Hi leilinee, Since Flink SQL is not supporting operator uid configuration there are only hard ways. State operator uid change + `execution.savepoint.ignore-unclaimed-state=true` would be the easy way.
Depending on you constraints either you use the state processor API and remove the operator which belongs to this statement or you not using the savepoint at all (no savepoint restore). Be aware that these ways you're going to loose state data so be careful. If you have the possibility to invest more time then with the state processor API you can do the state migration where you don't loose anything. BR, G On Sat, Feb 8, 2025 at 7:40 AM 李 琳 <leili...@outlook.com> wrote: > Dear All, > > In a Flink job using statementSet, I have two DMLs for index calculation. > I made a modification to one of the DMLs, changing the group keys from > "*distinct_id, > $city, $province, window_start, window_end*" to "*distinct_id, > window_start, window_end*". When attempting to restore the job from a > savepoint, Flink throws an exception due to an incompatibility in the key > serializer between the original and the new state. > > I'm seeking a way to make Flink skip the state related to the incompatible > key serializer and proceed with restoring the unmodified DMLs. Are there > any more effective approaches to achieve this? > > Best regards, leilinee > >
