Hi 如果异常退出,你在enable externalized checkpoint时候会配置作业退出时候的checkpoint保留策略,默认是作业failed的时候会保留externalized checkpoint。 你可以在相关目录下找到相关checkpoint的目录(判断条件chk-X目录下是否有_metadata文件,如果存在的话,就可以认为这个checkpoint是有效的),这样你就可以使用-s 参数指定从该externalized checkpoint恢复,Flink会将该checkpoint当作savepoint处理进行作业恢复。
祝好 唐云 ________________________________ From: 九思 <[email protected]> Sent: Friday, March 22, 2019 16:58 To: user-zh Subject: flink异常触发savepoint 请教老师,flink程序要停止的时候,都会手动去添加-s参数,去触发savepoint。但是如果程序是异常结束呢?要怎么去触发这个savepoint?
