Re: Flink sql task failure recovery does not work.

2021-05-13 Thread Guowei Ma
Hi I think you could configure some restart strategy[1] likes restart-strategy: fixed-delay [1] https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/execution/task_failure_recovery/#fixed-delay-restart-strategy Best, Guowei On Thu, May 13, 2021 at 12:02 PM 1095193...@qq.com

Flink sql task failure recovery does not work.

2021-05-12 Thread 1095193...@qq.com
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: