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.



1095193...@qq.com

Reply via email to