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