Thank you, I will do that. jinhai wang <jinhai...@gmail.com> 于2020年3月17日周二 下午5:58写道：
> 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 > > > 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> > 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> 于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 >>> >>> Cheers, >>> Till >>> >>> On Sat, Mar 14, 2020 at 4:07 AM LakeShen <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> 于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> >>>> > 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 >>>> > >>>> > > 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>> 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 >>>> > > >>>> > > >>>> > >>>> >>> >
