flink提交任务卡死,cancel job以后，在$FLINK_HOME/log/flink-appleyuchi-client-Desktop.log
发现该报错:
java.lang.NoClassDefFoundError: org/apache/hadoop/yarn/exceptions/YarnExceptionat java.lang.Class.forName0(Native Method)at java.lang.Class.forName(Class.java:264)at org.apache.flink.client.cli.CliFrontend.loadCustomCommandLine(CliFrontend.java:1073)at org.apache.flink.client.cli.CliFrontend.loadCustomCommandLines(CliFrontend.java:1029)at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:955)Caused by: java.lang.ClassNotFoundException: org.apache.hadoop.yarn.exceptions.YarnExceptionat .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)... 5 more
解决方案:
cp $HADOOP_HOME/share/hadoop/yarn/hadoop-yarn-api-3.1.2.jar share/hadoop/yarn/sources/hadoop-yarn-api-3.1.2-sources.jar $FLINK_HOME/lib
