微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

Flink运行时架构

系统架构

Flink整体架构

  • Flink整体架构中,最为重要的是JobManager和TaskManager。JobManager负责管理提交执行的作业,负责管理调度,因此在不开启高可用的情况下,一般只会有一个。TaskManager则是负责执行任务处理数据,所以可以存在多个。

  • JobManager和TaskManager的启动方式:
    1. 作为独立的集群(即standalone模式)进程,直接在机器上启动
    2. 在容器中启动
    3. 由yarn、K8S等资源调度平台调度启动

JobManager

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。

相关推荐