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 .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
