flink:如何配置flink,使taskmanagers在失败后自动重启?

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

如何配置flink,使TaskManager在失败后自动重新启动?

pbossiut

pbossiut1#

在yarn和kubernetes上,flink有一个本地资源管理器( YarnResourceManager 以及 KubernetesResourceManager )这将安排所请求的可用插槽数。在其他环境中,您需要使用特定于集群框架的机制来自己解决这个问题。
请注意,对于k8s,只有会话集群才受此新的、更主动的模式的支持 KubernetesResourceManager . 工作集群仍然需要按照文档中描述的老式方式进行管理。
此外,还有一些托管的flink环境,您可以在其中处理这些细节,例如ververica平台或kinesis数据分析。

相关问题