在启动任务的时候报错如下:
错误原因:
必须-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
更改后正常运行如下:
在启动任务的时候报错如下:
错误原因:
必须-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
更改后正常运行如下: