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 更改後正常運行如下:
相關文章
相關標籤/搜索