Flink学习(九)-jar 包提交给 flink 集群执行

时间:2024-04-26 13:11:05

一、界面执行

1,点击左侧的 submit new job,然后点击add New

2,粘贴程序入口,设置并行度

3,执行后,就可以在 taskManager 中找到相关任务了

二、控制台执行

在命令行中,在flink 的安装目录下,执行

bin/flink run -m node01:8081 -c com.wayne.demo.WordCountSocketStream ./flinkDemo-1.0-SNAPSHOT.jar

执行后,依旧在浏览器的 webUI 中,看相关信息即可