自学内容网 自学内容网

二百八十四、Flink——Flink提交任务两种方式(亲测、附截图)

一、目的

在IDEA中开发好项目后,如何在Flink上提交打包的jar包,有两种方式,分别是WEB UI 界面提交和通过命令行来提交

二、WEB UI 界面提交方式

1 在Submit New Job,点击右侧的+Add New,上传打包好的jar包

2 点击刚才上传的jar包,输入全类名和分区数

注意:由于我是单机环境,因为分区只能为1,否则会报错。这是一坑

          如果是集群,那分区数不超过集群数即可

3.点击Submit提交后,可以看到运行状态

4.端口输入数据,在Task Managers里可以看到

5.取消任务

在Running Jobs,点击运行任务,点击右侧的Cancel Job,就可以取消任务

6.在Completed Jobs查看结束的任务状态

三、命令行提交方式

1、打好的jar包上传Linux的flink安装路径下

2、执行Linux命令

# bin/flink run -m hurys23:8081 -c com.atguigu.chapter02.StreamWordCount ./FlinkTutorial-1.0-SNAPSHOT.jar

3.Running Jobs可以查看服务

4.端口输入数据TaskManager 看到结果

5.命令行取消任务

# ./bin/flink cancel 9d77b78eb8fd218248fea1f4e2c99e3c

6.在Completed Jobs查看结束的任务状态

搞定!开启Flink学习阶段


原文地址:https://blog.csdn.net/tiantang2renjian/article/details/145177490

免责声明:本站文章内容转载自网络资源,如侵犯了原著者的合法权益,可联系本站删除。更多内容请关注自学内容网(zxcms.com)!