We do use config like "restart-strategy: org.foobar.MyRestartStrategyFactoryFactory". Mainly to add additional metrics than the Flink provided ones.
On Thu, Sep 19, 2019 at 4:50 AM Zhu Zhu <reed...@gmail.com> wrote: > Thanks everyone for the input. > > The RestartStrategy customization is not recognized as a public interface > as it is not explicitly documented. > As it is not used from the feedbacks of this survey, I'll conclude that we > do not need to support customized RestartStrategy for the new scheduler in > Flink 1.10 > > Other usages are still supported, including all the strategies and > configuring ways described in > https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/task_failure_recovery.html#restart-strategies > . > > Feel free to share in this thread if you has any concern for it. > > Thanks, > Zhu Zhu > > Zhu Zhu <reed...@gmail.com> 于2019年9月12日周四 下午10:33写道： > >> Thanks Oytun for the reply! >> >> Sorry for not have stated it clearly. When saying "customized >> RestartStrategy", we mean that users implement an >> *org.apache.flink.runtime.executiongraph.restart.RestartStrategy* by >> themselves and use it by configuring like "restart-strategy: >> org.foobar.MyRestartStrategyFactoryFactory". >> >> The usage of restart strategies you mentioned will keep working with the >> new scheduler. >> >> Thanks, >> Zhu Zhu >> >> Oytun Tez <oy...@motaword.com> 于2019年9月12日周四 下午10:05写道： >> >>> Hi Zhu, >>> >>> We are using custom restart strategy like this: >>> >>> environment.setRestartStrategy(failureRateRestart(2, Time.minutes(1), >>> Time.minutes(10))); >>> >>> >>> --- >>> Oytun Tez >>> >>> *M O T A W O R D* >>> The World's Fastest Human Translation Platform. >>> oy...@motaword.com — www.motaword.com >>> >>> >>> On Thu, Sep 12, 2019 at 7:11 AM Zhu Zhu <reed...@gmail.com> wrote: >>> >>>> Hi everyone, >>>> >>>> I wanted to reach out to you and ask how many of you are using a >>>> customized RestartStrategy[1] in production jobs. >>>> >>>> We are currently developing the new Flink scheduler[2] which interacts >>>> with restart strategies in a different way. We have to re-design the >>>> interfaces for the new restart strategies (so called >>>> RestartBackoffTimeStrategy). Existing customized RestartStrategy will not >>>> work any more with the new scheduler. >>>> >>>> We want to know whether we should keep the way >>>> to customized RestartBackoffTimeStrategy so that existing customized >>>> RestartStrategy can be migrated. >>>> >>>> I'd appreciate if you can share the status if you are using customized >>>> RestartStrategy. That will be valuable for use to make decisions. >>>> >>>> [1] >>>> https://ci.apache.org/projects/flink/flink-docs-master/dev/task_failure_recovery.html#restart-strategies >>>> [2] https://issues.apache.org/jira/browse/FLINK-10429 >>>> >>>> Thanks, >>>> Zhu Zhu >>>> >>>
