Flink提交任务到yarn上启动踩坑(一)

【Flink提交任务到yarn上启动踩坑(一)】在启动任务的时候报错如下:
Flink提交任务到yarn上启动踩坑(一)
文章图片

错误原因:
必须-c在JAR文件之前指定参数,否则收到错误消息
更改后的提交代码如下:

./bin/flink run -m yarn-cluster -yqu info -yn 3 -c com.flink.dataset.WordCountTest /home/msns/wangyu/flink/flink_test_3.jar

更改后正常运行如下:
Flink提交任务到yarn上启动踩坑(一)
文章图片

    推荐阅读