flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Renjie Liu <liurenjie2...@gmail.com>
Subject Re: Flink stream job change and recovery
Date Fri, 04 Nov 2016 11:26:50 GMT
Hi, Fabian:
Will the checkpointed state be restored between streaming jobs?

On Fri, Nov 4, 2016 at 6:47 PM Fabian Hueske <fhueske@gmail.com> wrote:

> Yes, that is true for Flink 1.1.x.
>
> The upcoming Flink 1.2.0 release will be able to restore jobs from
> savepoints with different parallelism.
>
> 2016-11-04 11:24 GMT+01:00 Renjie Liu <liurenjie2008@gmail.com>:
>
> Hi, all:
> It seems that flink's checkpoint mechanism saves state per partition.
> However, if I want to change configuration of the job and resubmit the job,
> I can not recover from last checkpoint, right? Say I change the parallelism
> of kafka consumer and partitions assigned to each subtask will be
> different, then I'm not able to restart from last checkpoint, right?
> --
> Liu, Renjie
> Software Engineer, MVAD
>
>
> --
Liu, Renjie
Software Engineer, MVAD

Mime
View raw message