MAPREDUCE服务 MRS-Flink基本原理:Flink结构
Flink结构
Flink服务包含了两个重要的角色:FlinkResource和FlinkServer。
- FlinkResource:提供客户端配置管理,是必须安装的角色。
- FlinkServer:基于Web的作业管理二次开发平台,可直接在界面开发与管理FlinkSQL作业。具有运维管理界面化、作业开发SQL标准化等特点。
Flink结构如图2所示。
Flink整个系统包含三个部分:
- Client
- TaskManager
- JobManager
Flink系统的管理节点,管理所有的TaskManager,并决策用户任务在哪些TaskManager执行。JobManager在HA模式下可以有多个,但只有一个主JobManager。
如果您想了解更多关于Flink架构的信息,请参考链接:https://ci.apache.org/projects/flink/flink-docs-master/docs/concepts/flink-architecture/。
- MapReduce服务_什么是Flink_如何使用Flink
- MapReduce服务_什么是Kafka_如何使用Kafka
- MapReduce服务_什么是Hive_如何使用Hive
- MapReduce工作原理_MapReduce是什么意思_MapReduce流程_MRS_华为云
- Hudi服务_什么是Hudi_如何使用Hudi
- MapReduce服务_什么是Flume_如何使用Flume
- MapReduce服务_什么是存算分离_如何配置MRS集群存算分离
- MapReduce服务_什么是ZooKeeper_如何使用ZooKeeper
- 什么是Flink OpenSource SQL_数据湖探索_Flink OpenSource SQL
- MapReduce服务_什么是Loader_如何使用Loader