flink使用16-正确打包Flink程序并使用Cli提交任务
本文的计划是使用正确的maven插件打包当前教程代码库batch模块下的WordCount代码,并通过命令行的方式提交到Flink来启动任务。WordCount类即为Flink主方法类,该部分代码是Flink官方example的简单修改,只是对map方法填加了一点sleep来方便观察运行情况。
项目的运行环境使用Docker来部署Flink, Flink镜像可以从Docker hub上拉去,其D
...