flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: Flink stream job change and recovery
Date Fri, 04 Nov 2016 10:46:02 GMT
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
>

Mime
View raw message