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 <liurenjie2...@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 >
