Flink的job提交全流程及web ui提交任务方式

文章目录

背景
flink的job提交流程
web提交
- 开启支持web界面提交
- 打开web界面

背景

其实本来觉得这篇文章不需要写的，但是在网上搜了一下，有的提交的时候参数写的不全，还有的居然是收费文章！！那我就分享下个人使用经验吧~

flink的job提交流程

flink调用env.execute会有四个图：
StreamGraph、JobGraph、 ExecutionGraph、物理执行图
Flink 根据用户提交的代码生成 StreamGraph，经过优化生成 JobGraph，然后提交给 JobManager 进行处理，JobManager 会根据 JobGraph 生成 ExecutionGraph，ExecutionGraph 是 Flink 调度最核心的数据结构，JobManager 根据 ExecutionGraph 对 Job 进行调度。
在这里插入图片描述

web提交

开启支持web界面提交

vi flink-conf.yaml

web.submit.enable: true
1

打开web界面

http://ip:8081/#/overview
注意传入的参数在虚拟机上面的路径是 flink的bin目录下的etc，需要把文件传入对应目录，然后提交
在这里插入图片描述

随后左边的就可以看见tm和jm的状态了

相关阅读:
三十分钟学会Linux的基本操作
Kafka - 06 Kafka 集群环境搭建（三台虚拟机）
JavaSE进阶21天---第二十天---JavaSE（日志、logback日志、添加模板、类加载器、ressources文件夹)
选择振弦采集仪进行岩土工程监测时，根据不同工况选择合适的种类
基于51单片机气体检测报警系统-proteus仿真-源程序
033——常见数据结构
Tomcat调优【精简版】
C语言编写简易图书管理系统
微软放弃“封禁”商业开源！
ZYNQ下linux通过xdevcfg在线更新PL

原文地址：https://blog.csdn.net/MyNameIsWangYi/article/details/126420571