Ravikiran Borse created FLINK-22949:
---------------------------------------
Summary: java.io.InvalidClassException With Flink Kafka Beam
Key: FLINK-22949
URL: https://issues.apache.org/jira/browse/FLINK-22949
Project: Flink
Issue Type: Bug
Components: Connectors / Kafka
Affects Versions: 1.12.0
Reporter: Ravikiran Borse
Fix For: 1.12.0
Beam: 2.30.0
Flink: 1.12.0
Kafka: 2.6.0
ERROR:root:java.io.InvalidClassException:
org.apache.flink.streaming.api.graph.StreamConfig$NetworkInputConfig; local
class incompatible: stream classdesc serialVersionUID = 3698633776553163849,
local class serialVersionUID = -3137689219135046939
In Flink Logs
KafkaIO.Read.ReadFromKafkaViaSDF/{ParDo(GenerateKafkaSourceDescriptor),
KafkaIO.ReadSourceDescriptors} (1/1)#0 (b0c31371874208adb0ccaff85b971883)
switched from RUNNING to FAILED.
org.apache.flink.streaming.runtime.tasks.StreamTaskException: Could not
deserialize inputs
at
org.apache.flink.streaming.api.graph.StreamConfig.getInputs(StreamConfig.java:265)
~[flink-dist_2.12-1.12.0.jar:1.12.0]
at
org.apache.flink.streaming.api.graph.StreamConfig.getTypeSerializerIn(StreamConfig.java:280)
~[flink-dist_2.12-1.12.0.jar:1.12.0]
at
org.apache.flink.streaming.api.graph.StreamConfig.getTypeSerializerIn1(StreamConfig.java:271)
~[flink-dist_2.12-1.12.0.jar:1.12.0]
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.wrapOperatorIntoOutput(OperatorChain.java:639)
~[flink-dist_2.12-1.12.0.jar:1.12.0]
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:591)
~[flink-dist_2.12-1.12.0.jar:1.12.0]
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:526)
~[flink-dist_2.12-1.12.0.jar:1.12.0]
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.<init>(OperatorChain.java:164)
~[flink-dist_2.12-1.12.0.jar:1.12.0]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:485)
~[flink-dist_2.12-1.12.0.jar:1.12.0]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:531)
~[flink-dist_2.12-1.12.0.jar:1.12.0]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:722)
[flink-dist_2.12-1.12.0.jar:1.12.0]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:547)
[flink-dist_2.12-1.12.0.jar:1.12.0]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_282]
Caused by: java.io.InvalidClassException:
org.apache.flink.streaming.api.graph.StreamConfig$NetworkInputConfig; local
class incompatible: stream classdesc serialVersionUID = 3698633776553163849,
local class serialVersionUID = -3137689219135046939
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
