小令童鞋
·
【Flink】Flink基本架构
💡
原文中文，约900字，阅读约需2分钟。
📝
内容提要
Flink的Master节点包含Dispatcher、ResourceManager和JobManager三个组件，分别负责接收用户提交的作业、资源管理和具体作业的执行。集群Master节点在初始化时，会调用ClusterEntrypoint的runClusterEntrypoint()方法启动集群。
🎯
关键要点
-
Flink的Master节点包含Dispatcher、ResourceManager和JobManager三个组件。
-
Dispatcher负责接收用户提交的作业并启动JobManager服务。
-
ResourceManager负责管理集群中的资源，只有一个实例。
-
JobManager负责管理具体作业的执行，可能有多个JobManager同时运行。
-
用户提交作业时，代码会转化为JobGraph。
-
Standalone模式下，Client直接与Dispatcher连接提交作业。
-
Per-Job模式下，Client向资源管理系统申请资源后再提交作业。
-
Dispatcher启动JobManager后，JobManager向ResourceManager申请资源。
-
ResourceManager选择空闲Slot并通知相应的TM分配给JobManager。
-
Flink集群Master节点初始化时调用ClusterEntrypoint的runClusterEntrypoint()方法。
➡️
