Flink sql task failure recovery does not work.

Posted by on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-sql-task-failure-recovery-does-not-work-tp43691.html

Hi team,

   Following Task Failure Recovery document  https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/execution/task_failure_recovery/ ,  I have  enabled state.checkpoints.dir parameter in flink-conf.yaml.

 

    state.checkpoints.dir: hdfs://172.16.1.192:9000/flink-checkpoints

    state.savepoints.dir: hdfs://172.16.1.192:9000/flink-savepoints

    

    However, Flink sql Task still throw Exception org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy.  Apparently, no restart strategy enabled. Do we have enabled other configuration rather than state.checkpoints.dir.  Thanks for any suggestions.

---

[hidden email]