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
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