Hi Yubraj Singh, Can you try submitting with HADOOP_CLASSPATH=`hadoop classpath` set? [1] For example: HADOOP_CLASSPATH=`hadoop classpath` bin/flink run [...]
Best, Gary [1] https://ci.apache.org/projects/flink/flink-docs-master/ops/deployment/hadoop.html#configuring-flink-with-hadoop-classpaths On Tue, Aug 21, 2018 at 4:23 PM, yuvraj singh <19yuvrajsing...@gmail.com> wrote: > Hi , > > i am getting a error while running a flink job on yarn cluster , its > running fine when i run it on flink standalone cluster > > java.lang.NoClassDefFoundError: com/sun/jersey/core/util/ > FeaturesAndProperties > > at 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 java.net.URLClassLoader.access$100(URLClassLoader.java:73) > > at java.net.URLClassLoader$1.run(URLClassLoader.java:368) > > at java.net.URLClassLoader$1.run(URLClassLoader.java:362) > > at java.security.AccessController.doPrivileged(Native Method) > > at java.net.URLClassLoader.findClass(URLClassLoader.java:361) > > 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) > > at org.apache.hadoop.yarn.client.api.TimelineClient.createTimelineClient( > TimelineClient.java:55) > > at org.apache.hadoop.yarn.client.api.impl.YarnClientImpl. > createTimelineClient(YarnClientImpl.java:181) > > at org.apache.hadoop.yarn.client.api.impl.YarnClientImpl. > serviceInit(YarnClientImpl.java:168) > > at org.apache.hadoop.service.AbstractService.init( > AbstractService.java:163) > > at org.apache.flink.yarn.cli.FlinkYarnSessionCli.getClusterDescriptor( > FlinkYarnSessionCli.java:966) > > at org.apache.flink.yarn.cli.FlinkYarnSessionCli.createDescriptor( > FlinkYarnSessionCli.java:269) > > at org.apache.flink.yarn.cli.FlinkYarnSessionCli.createClusterDescriptor( > FlinkYarnSessionCli.java:444) > > at org.apache.flink.yarn.cli.FlinkYarnSessionCli.createClusterDescriptor( > FlinkYarnSessionCli.java:92) > > at org.apache.flink.client.cli.CliFrontend.runProgram( > CliFrontend.java:225) > > at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:214) > > at org.apache.flink.client.cli.CliFrontend.parseParameters( > CliFrontend.java:1025) > > at org.apache.flink.client.cli.CliFrontend.lambda$main$9( > CliFrontend.java:1101) > > at java.security.AccessController.doPrivileged(Native Method) > > at javax.security.auth.Subject.doAs(Subject.java:422) > > at org.apache.hadoop.security.UserGroupInformation.doAs( > UserGroupInformation.java:1754) > > at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured( > HadoopSecurityContext.java:41) > > at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1101) > > Caused by: java.lang.ClassNotFoundException: com.sun.jersey.core.util. > FeaturesAndProperties > > 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) > > ... 29 more > > > please help me > > > thanks > > Yubraj singh >
