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 strategy at your job and
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
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