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