一、创建Maven项目 - ScalaWordCount 三、利用mvn命令打包Maven项目 三、上传项目jar包到Flink集群主节点 四、启动Flink Standalone集群 五、将应用提交到Flink集群运行
(一)不设置输入参数,只设置输出参数 (二)既设置输入参数,又设置输出参数
一、创建Maven项目 - ScalaWordCount
创建Maven项目 - ScalaWordCount
修改pom文件,添加依赖,配置插件

一、创建Maven项目 - ScalaWordCount 三、利用mvn命令打包Maven项目 三、上传项目jar包到Flink集群主节点 四、启动Flink Standalone集群 五、将应用提交到Flink集群运行
(一)不设置输入参数,只设置输出参数 (二)既设置输入参数,又设置输出参数
一、创建Maven项目 - ScalaWordCount
创建Maven项目 - ScalaWordCount
修改pom文件,添加依赖,配置插件