一、目的
在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学习阶段
