Hi all, I’m using the Flink operator and have a jo...
# troubleshooting
a
Hi all, I’m using the Flink operator and have a job that I have defined using the FlinkSessionJob CR. I’m trying to set a specific Restart Strategy on my FlinkSessionJob, but based on the logs I’m seeing when the job is submitted, it’s not honoring my configuration and is instead falling back to the default Restart Strategy. (fixed-delay with Integer.MAX restart attempts) Here is a section from my FlinkSessionJob yml:
Copy code
flinkConfiguration:
    restart-strategy.type: "failure-rate"
    restart-strategy.failure-rate.max-failures-per-interval: "10"
    restart-strategy.failure-rate.failure-rate-interval: "1 min"
    restart-strategy.failure-rate.delay: "5 s"
And here is the log output when the job is submitted:
Copy code
INFO  org.apache.flink.runtime.jobmaster.JobMaster - Using restart back off time strategy FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=2147483647, backoffTimeMS=1000) for Flink Streaming Job (000000005a6cddc20000000000000001).
Any ideas? Do I have it configured incorrectly?