可以通过使用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/