可以通过使用rest api 定时拉取checkpoints的状态
rest api uri为 {cluster}/jobs/{jobid}/checkpoints返回的是json，里面有最近一次的ck记录和 历史记录。 ________________________________ 发件人: bradyMk <zhbm...@126.com> 发送时间: 2020年10月30日 6:52 收件人: user-zh@flink.apache.org <user-zh@flink.apache.org> 主题: Re: flink任务挂掉后自动重启 谢谢您的解答~ 重启策略确实可以解决任务故障重启，但是有的时候（例如集群资源不够），任务会直接被kill掉，我想问的是针对被kill掉的任务，有没有什么方法可以自动重启，特别是带有ck的任务，如果想要自动重启，如何在启动的时候自动去hdfs上获取最新的ck地址呢？ ----- Best Wishes -- Sent from: http://apache-flink.147419.n8.nabble.com/
