Flink提交任务报错:NoClassDefFoundError:javax/ws/rs/ext/MessageBodyReader


[yarn&＃64;master01 flink-1.12.0]$ flink run -t yarn-per-job -c org.apache.flink.streaming.examples.socket.SocketWindowWordCount examples/streaming/SocketWindowWordCount.jar --port 9999
2021-03-31 14:42:41,701 WARN org.apache.flink.yarn.configuration.YarnLogConfigUtil [] - The configuration directory (&＃39;/opt/tools/flink-1.12.0/conf&＃39;) already contains a LOG4J config file.If you want to use logback, then please delete or rename the log configuration file.
java.lang.NoClassDefFoundError: javax/ws/rs/ext/MessageBodyReaderat java.lang.ClassLoader.defineClass1(Native Method)at java.lang.ClassLoader.defineClass(ClassLoader.java:763)at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)at java.net.URLClassLoader.defineClass(URLClassLoader.java:467).....at org.apache.flink.client.program.StreamContextEnvironment.executeAsync(StreamContextEnvironment.java:128)at org.apache.flink.client.program.StreamContextEnvironment.execute(StreamContextEnvironment.java:76)at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1822)at org.apache.flink.streaming.examples.socket.SocketWindowWordCount.main(SocketWindowWordCount.java:93)at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)at java.lang.reflect.Method.invoke(Method.java:498)........
Caused by: java.lang.ClassNotFoundException: javax.ws.rs.ext.MessageBodyReaderat 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)... 76 more

二. 处理方式

下载 javax.ws.rs-api-2.0.jar放到${FLINK_HOME}的lib目录即可.

下载地址 : javax.ws.rs-api-2.0.jar