Re: Resuming Savepoint issue with upgraded Flink version 1.11.2

2020-10-23 Thread Till Rohrmann
Hi Partha, have you set explicit operator uids [1]? This is usually recommended in order to ensure that Flink can match operator state across re-submissions in particular when doing job upgrades. If you haven't set the uids explicitly, then Flink will generate them automatically. It could be the c

Resuming Savepoint issue with upgraded Flink version 1.11.2

2020-10-22 Thread Partha Mishra
Hi, We are trying to save checkpoints for one of the flink job running in Flink version 1.9 and tried to resume the same flink job in Flink version 1.11.2. We are getting the below error when trying to restore the saved checkpoint in the newer flink version. Can Cannot map checkpoint/savepoint