flink的版本是1.10.1

yarn-session.sh啟動后出現如下報錯:

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

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。