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.
Advertising
# 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
