Hi Deepak, are you running Flink streaming jobs with checkpointing enabled? In this case Flink will check if you've set a restart strategy at your job and if not it will set the fixed delay restart strategy. This will effectively overwrite the default restart strategy which you define in the flink-conf.yaml file.
Cheers, Till On Thu, Sep 22, 2016 at 10:01 PM, Deepak Jha <dkjhan...@gmail.com> wrote: > Hi All, > I tried to use FailureRate restart strategy by setting values for it in > flink-conf.yaml but flink (v 1.1.2) did not pick it up. > > # Flink Restart strategy > restart-strategy: failure-rate > restart-strategy.failure-rate.delay: 120 s > restart-strategy.failure-rate.failure-rate-interval: 12 minute > restart-strategy.failure-rate.max-failures-per-interval: 300 > > It works when I set it up explicitly in topology using > *env.setRestartStrategy * > > PFA snapshot of the Jobmanager log. > Thanks, > Deepak Jha > >
