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?

回复