Hi Yubraj, The solution to a similar problem from StackOverflow is to explicitly define the serialVersionUID in your class. For more information, please visit here.[1]
[1]: https://stackoverflow.com/questions/27647992/how-resolve-java-io-invalidclassexception-local-class-incompatible-stream-clas Thanks, vino. yuvraj singh <19yuvrajsing...@gmail.com> 于2018年8月22日周三 上午1:42写道： > it works , but now i am getting > > org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot > instantiate user function. > at > org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(StreamConfig.java:239) > at > org.apache.flink.streaming.runtime.tasks.OperatorChain.<init>(OperatorChain.java:104) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:267) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711) > at java.lang.Thread.run(Thread.java:745) > Caused by: java.io.InvalidClassException: > com.fasterxml.jackson.databind.ObjectMapper; local class incompatible: stream > classdesc serialVersionUID = 1, local class serialVersionUID = 2 > at java.io.ObjectStreamClass.initNonProxy(ObjectStreamClass.java:616) > at > java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1630) > at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1521) > at > java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1781) > at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1353) > at > java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2018) > at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1942) > at > java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1808) > at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1353) > at > java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2018) > at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1942) > at > java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1808) > at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1353) > at > java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2018) > at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1942) > at > java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1808) > at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1353) > at > java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2018) > at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1942) > at > java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1808) > at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1353) > at java.io.ObjectInputStream.readObject(ObjectInputStream.java:373) > at > org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:502) > at > org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:489) > at > org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:477) > at > org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:438) > at > org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(StreamConfig.java:224) > ... 4 more > > > thanks > > Yubraj Singh > > > > On Tue, Aug 21, 2018 at 10:54 PM Gary Yao <g...@data-artisans.com> wrote: > >> 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 >>> >> >>
