flink的版本是1.10.1

yarn-session.sh啟動(dòng)后出現(xiàn)如下報(bào)錯(cuò):

java.lang.NoClassDefFoundError: org/apache/hadoop/fs/Path
?? ?at org.apache.flink.yarn.cli.FlinkYarnSessionCli.getLocalFlinkDistPathFromCmd(FlinkYarnSessionCli.java:276)
?? ?at org.apache.flink.yarn.cli.FlinkYarnSessionCli.applyDescriptorOptionToConfig(FlinkYarnSessionCli.java:403)
?? ?at org.apache.flink.yarn.cli.FlinkYarnSessionCli.applyCommandLineOptionsToConfiguration(FlinkYarnSessionCli.java:335)
?? ?at org.apache.flink.yarn.cli.FlinkYarnSessionCli.run(FlinkYarnSessionCli.java:526)
?? ?at org.apache.flink.yarn.cli.FlinkYarnSessionCli.lambda$main$5(FlinkYarnSessionCli.java:785)
?? ?at org.apache.flink.runtime.security.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30)
?? ?at org.apache.flink.yarn.cli.FlinkYarnSessionCli.main(FlinkYarnSessionCli.java:785)
Caused by: java.lang.ClassNotFoundException: org.apache.hadoop.fs.Path
?? ?at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
?? ?at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
?? ?at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335)
?? ?at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
?? ?... 7 more
?

解決方案:

$FLINK_HOME/lib下面放置flink-shaded-hadoop-3-uber-3.1.1.7.0.3.0-79-7.0.jar

總結(jié)

以上是生活随笔為你收集整理的flink启动出现java.lang.NoClassDefFoundError: org/apache/hadoop/fs/Path的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。