Hi Cong,
No never set the uid for the operators.
Regards,
Partha Mishra
From: Congxian Qiu
Sent: Friday, October 30, 2020 10:51 AM
To: Partha Mishra
Cc: Sivaprasanna ; user@flink.apache.org
Subject: Re: Resuming Savepoint issue with upgraded Flink version 1.11.2
Hi Partha
The exception
Hi,
None of the operator is renamed or removed. Testing is carried out with exactly
same binary used with 1.9 and 1.11.2. Checkpoint saved in 1.9 is not being able
to retrieve in 1.11.2
From: Sivaprasanna
Sent: Friday, October 23, 2020 10:57 AM
To: Partha Mishra
Cc: user@flink.apache.org
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