hi, 提供一个方案,平台层可以做到作业自动拉起,那么需要平台层有这些信息。
1、作业启动的时候保存一下作业的 jobid 信息 2、平台轮训检测作业的状态,如果作业挂了,直接从配置的 checkpoint 基础路径 + jobid 目录下去找最新的目录(里面含 _metadata) eg: hdfs:/flink/checkpoints/9b4cddb385b0c5db96b0774769867673/chk-15109 然后平台层将作业从 checkpoint 拉起,当然这个是否自动拉起,拉起的次数可以让用户去选择。 Best! zhisheng bradyMk <zhbm...@126.com> 于2020年10月31日周六 下午4:20写道: > 好的,我去试试这种方法,感谢~ > > > > ----- > Best Wishes > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ >