[jira] [Created] (FLINK-21359) CompatibilityResult issues with Flink 1.9.0

[Shang Yuanchun (Jira)]

Siva created FLINK-21359:
----------------------------

             Summary: CompatibilityResult issues with Flink 1.9.0
                 Key: FLINK-21359
                 URL: https://issues.apache.org/jira/browse/FLINK-21359
             Project: Flink
          Issue Type: Bug
         Environment: DEV
            Reporter: Siva


I am using emr 5.28.0 and flink 1.9.0

 

Source code is working fine with emr 5.11.0 and flink 1.3.2, but the same source code is throwing the following stack track with emr 5.28.0 and flink 1.9.0

 

java.lang.NoClassDefFoundError: org/apache/flink/api/common/typeutils/CompatibilityResult
 at java.lang.Class.getDeclaredMethods0(Native Method)
 at java.lang.Class.privateGetDeclaredMethods(Class.java:2701)
 at java.lang.Class.getDeclaredMethod(Class.java:2128)
 at java.io.ObjectStreamClass.getPrivateMethod(ObjectStreamClass.java:1643)
 at java.io.ObjectStreamClass.access$1700(ObjectStreamClass.java:79)
 at java.io.ObjectStreamClass$3.run(ObjectStreamClass.java:520)
 at java.io.ObjectStreamClass$3.run(ObjectStreamClass.java:494)
 at java.security.AccessController.doPrivileged(Native Method)
 at java.io.ObjectStreamClass.<init>(ObjectStreamClass.java:494)
 at java.io.ObjectStreamClass.lookup(ObjectStreamClass.java:391)
 at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1134)
 at java.io.ObjectOutputStream.writeArray(ObjectOutputStream.java:1378)
 at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1174)
 at java.io.ObjectOutputStream.defaultWriteFields(ObjectOutputStream.java:1548)
 at java.io.ObjectOutputStream.writeSerialData(ObjectOutputStream.java:1509)
 at java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1432)
 at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1178)
 at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:348)
 at org.apache.flink.util.InstantiationUtil.serializeObject(InstantiationUtil.java:586)
 at org.apache.flink.util.InstantiationUtil.writeObjectToConfig(InstantiationUtil.java:515)
 at org.apache.flink.streaming.api.graph.StreamConfig.setTypeSerializer(StreamConfig.java:193)
 at org.apache.flink.streaming.api.graph.StreamConfig.setTypeSerializerIn1(StreamConfig.java:143)
 at org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator.setVertexConfig(StreamingJobGraphGenerator.java:438)
 at org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator.createChain(StreamingJobGraphGenerator.java:272)
 at org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator.createChain(StreamingJobGraphGenerator.java:238)
 at org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator.createChain(StreamingJobGraphGenerator.java:238)
 at org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator.createChain(StreamingJobGraphGenerator.java:243)
 at org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator.setChaining(StreamingJobGraphGenerator.java:207)
 at org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator.createJobGraph(StreamingJobGraphGenerator.java:159)
 at org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator.createJobGraph(StreamingJobGraphGenerator.java:94)
 at org.apache.flink.streaming.api.graph.StreamGraph.getJobGraph(StreamGraph.java:737)
 at org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:88)
 at org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:122)
 at org.apache.flink.client.cli.CliFrontend.runProgram(CliFrontend.java:227)
 at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:205)
 at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1010)
 at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1083)
 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:1844)
 at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
 at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1083)
Caused by: java.lang.ClassNotFoundException: org.apache.flink.api.common.typeutils.CompatibilityResult
 at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
 at java.lang.ClassLoader.loadClass(ClassLoader.java:418)
 at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:352)
 at java.lang.ClassLoader.loadClass(ClassLoader.java:351)
 ... 42 more



--
This message was sent by Atlassian Jira
(v8.3.4#803005)