其他分享
首页 > 其他分享> > Flink简单学习

Flink简单学习

作者:互联网

一:Flink基本架构

1.JobManager和TaskManager

JobManager:也称之为Master用于协调分布式执行,它们用来调度task协调检查点,协调失败时恢复等

TaskManager:也称之为Worker,用于执行一个dataflow的task(或者特殊的subtask)、数据缓冲和datastream的交换

 

 

 Master和Worker处理器可以直接在物理机上启动

Worker连接到Master,告知自身的可用性进而获得任务分配

2.无界数据流和有界数据流

无界数据流:无界数据流有一个开始但是没有结束

有界数据流:有界数据流有明确定义的开始和结束

批处理的特点是有界、持久、大量,批处理非常适合需要访问全套记录才能完成的计算工作

流处理的特点是无界、实时、而是对通过系统传输的每个数据项执行操作,一般用于实时统计。

二:Flink运行框架

1.任务提交流程

Flink提交任务后Client向HDFS上传Flink的jar包和配置

ResourceManager分配容器资源并通知对用的NodeManager启动ApplicationMaster

ApplicationMaster启动后加载Flink的jar包和配置构建环境,然后启动JobManager

ApplicationMaster向ResourceManager申请资源启动TaskManager,ResourceManager分配容器资源后由ApplicationMaster加载Flink的jar包和配置构建环境并启动TaskManager,TaskManager启动后向JobManager发送心跳包,并等待JobManager向其分配任务。

2.TaskManager 与solts

TaskManager是一个JVM进程,它可能会在独立的线程上执行一个或多个subtask

worker通过task slot来进行控制

每个task slot表示TaskManager拥有资源的一个固定大小的子集。

一个TaskManager有三个slot,那么会把他管理的内存分配给三个slot。

假如一个taskManager有3个slot,他就会给每个slot分配1/3的内存资源,目前slot不会对cpu进行隔离。同一个taskManager中的slot会共享网络资源和心跳信息。

在Flink中并不是一个slot只可以执行一个task,在某些情况下,一个slot中也可能执行多个task

 

 

slot仅用来隔离task受管理的内存。

Task Slot是静态的概念是指TaskManager具有的并发执行能力

 

标签:slot,task,Flink,JobManager,TaskManager,学习,简单,数据流
来源: https://www.cnblogs.com/wybf/p/15455539.html