RE: Resuming Savepoint issue with upgraded Flink version 1.11.2

2020-10-29 Thread Partha Mishra
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

RE: Resuming Savepoint issue with upgraded Flink version 1.11.2

2020-10-23 Thread Partha Mishra
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

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