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-29 Thread Congxian Qiu
aprasanna > *Sent:* Friday, October 23, 2020 10:57 AM > *To:* Partha Mishra > *Cc:* user@flink.apache.org > *Subject:* Re: Resuming Savepoint issue with upgraded Flink version 1.11.2 > > > > Hi, > > > > Have you dropped or renamed any operator from the original

RE: Resuming Savepoint issue with upgraded Flink version 1.11.2

2020-10-23 Thread Partha Mishra
Subject: Re: Resuming Savepoint issue with upgraded Flink version 1.11.2 Hi, Have you dropped or renamed any operator from the original job? If yes, and you are okay with discarding the state of that operator, you can submit the job with --allowNonRestoredState or -n. https://ci.apache.org

Re: Resuming Savepoint issue with upgraded Flink version 1.11.2

2020-10-22 Thread Sivaprasanna
Hi, Have you dropped or renamed any operator from the original job? If yes, and you are okay with discarding the state of that operator, you can submit the job with --allowNonRestoredState or -n. https://ci.apache.org/projects/flink/flink-docs-stable/ops/state/savepoints.html#allowing-non-restored