一、界面执行
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 中,看相关信息即可