使用Flink版本1.10.1
启动命令
flink run -m yarn-cluster -yd -ynm DTSLauncher -yjm 1024m -ytm 2048m -yn 3 -ys 1 -c com.br.dts.stream.launcher.DTSLauncher /data/module/br-dts/dts-launcher-task/launcher/br-dts-1.0-SNAPSHOT.jar
报错原因:flink1.10.1不支持-yn参数,去掉即可
flink run 报错Could not build the program from JAR file.
原文:https://www.cnblogs.com/gentlescholar/p/15102604.html