flink群集重新启动时自动恢复作业

bwntbbo3  于 2021-06-24  发布在  Flink
关注(0)|答案(1)|浏览(613)

我在一个独立的flink集群上运行作业,其中有一个作业管理器,在docker容器中运行。每当集群崩溃并重新启动时,我都必须再次手动提交作业以启动它们。有没有办法让flink在集群再次运行时自动恢复作业?

dzjeubhm

dzjeubhm1#

如果作业因引发异常而崩溃,只要(1)启用了检查点(由于需要某些配置,默认情况下禁用了检查点),并且(2)没有设置阻止重新启动的重新启动策略(默认的重新启动策略很好),作业管理器就会自动重新启动它。如果独立集群中的任务管理器完全失败,则需要启动另一个任务管理器。
要配置作业管理器故障切换,请参阅有关独立群集的高可用性的文档。

相关问题