Re: FailureRate Restart Strategy is not picked from Config file

2016-09-28 Thread Deepak Jha
Hi Till, yes, I have enabled checkpointing from my job. Thanks for your help :) On Mon, Sep 26, 2016 at 3:18 AM, Till Rohrmann wrote: > Hi Deepak, > > are you running Flink streaming jobs with checkpointing enabled? In this > case Flink will check if you've set a restart

Re: FailureRate Restart Strategy is not picked from Config file

2016-09-26 Thread Till Rohrmann
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

FailureRate Restart Strategy is not picked from Config file

2016-09-22 Thread Deepak Jha
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