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 >> >
