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

Reply via email to