flink的提交任务
1.web页面上传程序代码,填入要1.执行的maind的全类名,2.并行度3.接收机器和端口号,
2.还有一种就是直接在项目(idea)中就直接执行程序!结果将会打印在控制台,
3.再有一种就是在linux中提交任务
将jar包上传到lunux,到flink的命令下bin下,
-c 指定main方法的全类名
-n 指定main的名字
-p 指定并行度
-m 指定jobmanager的地址 doit01:8081
最后面跟参数
例:
[root@doit02 flink-1.10.0]# bin/flink run -m doit01:8081 -c com._51doit.flink.StreamingWordCount -p 2 /root/Flink_java-1.0-SNAPSHOT.jar doit01 8888
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。
