在 Plink 上提交 Flink 自带的 flink-1.9.1\examples\streaming\WordCount.jar,然运行。
注意: 由于独立部署和容器化部署的 Flink 版本可能不一样,最好使用对应的 WordCount Jar 版本。
-
独立部署(Flink 1.9):
下载链接: https://mirror.bit.edu.cn/apache/flink/flink-1.9.3/flink-1.9.3-bin-scala_2.11.tgz
Jar 目录: f${FLINK_HOME}examples\streaming\WordCount.jar。 -
Docker 部署(Flink 1.10):
下载链接: https://mirrors.bfsu.edu.cn/apache/flink/flink-1.10.1/flink-1.10.1-bin-scala_2.11.tgz
Jar 目录: ${FLINK_HOME}\examples\streaming\WordCount.jar
作业列表编辑或新建作业之后会自动跳转到编辑作业的页面。填写参数,上传 Jar,保存即可。如下所示:
Word Count MainClass: org.apache.flink.streaming.examples.wordcount.WordCount
在作业详情页的右侧功能按钮点击启动,即可启动作业,同时页面会自动刷新(当前刷新频率为 1s)