将在IDEA开发的flink项目提交到flink集群中

本文运行环境：window上的idea，虚拟机centos上的flink单机模式

启动集群

在centos上启动flink

进入flink安装目录 cd /usr/flink-1.13.1
输入启动命令 ./bin/start-cluster.sh

image.png

项目打包

已经运行过的的flink-Scala项目在target包中（已经运行过的项目会自动编译）
image.png
没有运行过的需要先使用maven1进行编译
image.png

点击package进行打包
image.png

打包成功
image.png

从flink的web页面提交项目

image.png
image.png

设置作业参数

image.png

并行度设置优先级：算子并行度 > 全局设置的并行度 > web页面中设置的并行度