這個是Flink 1.11.1 使用yarn-session 出現的錯誤;原因是在Flink1.11 之后不再提供flink-shaded-hadoop-*” jars
需要在yarn-session.sh 文件中添加 或者在環境變量中添加
export HADOOP_CLASSPATH=`hadoop classpath`

所以要仔細閱讀官網信息,基本上好多東西根據官網來,都能解決
這個是Flink 1.11.1 使用yarn-session 出現的錯誤;原因是在Flink1.11 之后不再提供flink-shaded-hadoop-*” jars
需要在yarn-session.sh 文件中添加 或者在環境變量中添加
所以要仔細閱讀官網信息,基本上好多東西根據官網來,都能解決
本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。