Hi Jing, Yup, what you're describing is what I want. I also tried the approach you suggested and it works. I'm going to take that approach for the moment and create a Jira issue for this feature.
On Sun, May 30, 2021 at 8:57 PM JING ZHANG <beyond1...@gmail.com> wrote: > Hi Kai, > > Do you try to find a way to hot update checkpoint interval or > disable/enable checkpoint without stop and restart job? > Unfortunately, it is not supported yet, AFAIK. > You're very welcome to create an issue and describe your needs here (Flink’s > Jira <http://issues.apache.org/jira/browse/FLINK>) . > At present, you may would like to use the following temporary solution: > 1. set a bigger value as checkpoint interval, start your job > 2. do a savepoint after cold start is completed > 3. set a normal value as checkpoint interval, restart the job from > savepoint > > Best regards, > JING ZHANG > > Kai Fu <zzfu...@gmail.com> 于2021年5月30日周日 下午7:13写道： > >> Hi team, >> >> We want to know if Flink has some dynamic configuration of the checkpoint >> interval. Our use case has a cold start phase where the entire dataset is >> replayed from the beginning until the most recent ones. >> >> In the cold start phase, the resources are fully utilized and the >> backpressure is high for all upstream operators, causing the checkpoint >> timeout constantly. The real production traffic is far less than that and >> the current provisioned resource is capable of handling it. >> >> We're thinking if Flink can support the dynamic checkpoint config to >> bypass the checkpoint operation or make it less frequent on the cold start >> phase to speed up the process, while making the checkpoint normal again >> once the cold start is completed. >> >> -- >> *Best wishes,* >> *- Kai* >> > -- *Best wishes,* *- Kai*
