Hi LakeShen You also must assign IDs to all operators of an application. Otherwise, you may not be able to recover from checkpoint
Doc: https://ci.apache.org/projects/flink/flink-docs-stable/ops/upgrading.html#matching-operator-state <https://ci.apache.org/projects/flink/flink-docs-stable/ops/upgrading.html#matching-operator-state> Best Regards jinhai...@gmail.com > 2020年3月17日 下午5:51，Till Rohrmann <trohrm...@apache.org> 写道： > > Let us know if you should run into any problems. The state processor API is > still young and could benefit from as much feedback as possible. > > Cheers, > Till > > On Tue, Mar 17, 2020 at 2:57 AM LakeShen <shenleifight...@gmail.com > <mailto:shenleifight...@gmail.com>> wrote: > Wow,this feature is look so good,I will see this feature. > Thank you to reply me , Till😀. > > Best Regards, > LakeShen > > Till Rohrmann <trohrm...@apache.org <mailto:trohrm...@apache.org>> > 于2020年3月17日周二 上午4:17写道： > If you want to change the max parallelism then you need to take a savepoint > and use Flink's state processor API [1] to rewrite the max parallelism by > creating a new savepoint from the old one. > > [1] > https://ci.apache.org/projects/flink/flink-docs-stable/dev/libs/state_processor_api.html > > <https://ci.apache.org/projects/flink/flink-docs-stable/dev/libs/state_processor_api.html> > > Cheers, > Till > > On Sat, Mar 14, 2020 at 4:07 AM LakeShen <shenleifight...@gmail.com > <mailto:shenleifight...@gmail.com>> wrote: > Hi Eleanore , if you resume from savepoint , you can't change the flink > operator's max parallelism . > > Eleanore Jin <eleanore....@gmail.com <mailto:eleanore....@gmail.com>> > 于2020年3月14日周六 上午12:51写道： > > > Hi Piotr, > > Does this also apply to savepoint? (meaning the max parallelism should not > > change for job resume from savepoint?) > > > > Thanks a lot! > > Eleanore > > > > On Fri, Mar 13, 2020 at 6:33 AM Piotr Nowojski <pi...@ververica.com > > <mailto:pi...@ververica.com>> > > wrote: > > > > > Hi, > > > > > > Yes, you can change the parallelism. One thing that you can not change is > > > “max parallelism”. > > > > > > Piotrek > > > > > > > On 13 Mar 2020, at 04:34, Sivaprasanna <sivaprasanna...@gmail.com > > > > <mailto:sivaprasanna...@gmail.com>> > > > wrote: > > > > > > > > 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 <shenleifight...@gmail.com > > > > <mailto:shenleifight...@gmail.com> > > > <mailto:shenleifight...@gmail.com <mailto:shenleifight...@gmail.com>>> > > > 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 > > > > > > > >
