阿里Flink进阶—1、Runtime核心机制

一、整体API架构

阿里Flink进阶—1、Runtime核心机制
Flink整体结构.png

1.1 runtime核心架构

阿里Flink进阶—1、Runtime核心机制
runtime核心架构.png
阿里Flink进阶—1、Runtime核心机制
image.png

Master三部分:Dispatcher、JM、RM
Dispatcher:接受用户作业,拉起JM;
JM(Jobmanager):管理作业运行
RM(Resourcemanager):资源分配 ,全集群1个

三个均在AppMaster进程里面。

1.2 两种模式

阿里Flink进阶—1、Runtime核心机制
image.png