Cancel the flink task and restore from checkpoint ,can I change the flink operator's parallelism

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Cancel the flink task and restore from checkpoint ,can I change the flink operator's parallelism

LakeShen
Hi community,
      I have a question is that I cancel the flink task and retain the
checkpoint dir, then restore from the checkpoint dir ,can I change the
flink operator's parallelism,in my thoughts, I think I can't change the
flink operator's parallelism,but I am not sure.
     Thanks to your reply.

Best wishes,
LakeShen
Reply | Threaded
Open this post in threaded view
|

Re: Cancel the flink task and restore from checkpoint ,can I change the flink operator's parallelism

Sivaprasanna
I think you can modify the operator’s parallelism. It is only if you have
set maxParallelism, and while restoring from a checkpoint, you shouldn’t
modify the maxParallelism. Otherwise, I believe the state will be lost.

-
Sivaprasanna

On Fri, 13 Mar 2020 at 9:01 AM, LakeShen <[hidden email]> wrote:

> Hi community,
>       I have a question is that I cancel the flink task and retain the
> checkpoint dir, then restore from the checkpoint dir ,can I change the
> flink operator's parallelism,in my thoughts, I think I can't change the
> flink operator's parallelism,but I am not sure.
>      Thanks to your reply.
>
> Best wishes,
> LakeShen
>