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

打印 上一主题 下一主题

主题 1023|帖子 1023|积分 3069

马上注册,结交更多好友,享用更多功能,让你轻松玩转社区。

您需要 登录 才可以下载或查看,没有账号?立即注册

x
一、目的

在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学习阶段

免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。
回复

使用道具 举报

0 个回复

倒序浏览

快速回复

您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

知者何南

论坛元老
这个人很懒什么都没写!
快速回复 返回顶部 返回列表