Blink学习（二）：代码运行框架

1 运算节点

通过这张图我们可以看到，在一个 DAG 图中，不能被 chain 在一起的 operator 会被分隔到不同 的 Task 中，也就是说，Task 是 Flink 中资源调度的最小单位。

2 运行框架

Blink 运行时包括两类进程:

JobManager（又称为 JobMaster）：协调 Task 的分布式执行，包括调度 Task、协调创 checkpoint 以及当 job failover 时协调各个 Task 从 checkpoint 恢复等。TaskManager（又称为 Worker）：执行 dataflow 中的 Tasks，包括内存 buffer 的分配、 Data Stream 的传递等。

下图中的Task Slot中运行的就是Task。 Task Slot中就是常说的计算节点。

如果感兴趣，欢迎关注微信技术公众号