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
Logo

魔乐社区(Modelers.cn) 是一个中立、公益的人工智能社区,提供人工智能工具、模型、数据的托管、展示与应用协同服务,为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作,由全产业链共同建设、共同运营、共同享有,推动国产AI生态繁荣发展。

更多推荐