hunter created FLINK-38354:
------------------------------
Summary: ClassCastException occurs when submitting a task to flink
cdc
Key: FLINK-38354
URL: https://issues.apache.org/jira/browse/FLINK-38354
Project: Flink
Issue Type: Bug
Components: Flink CDC
Affects Versions: 3.0.0
Environment: Flink CDC 3.4.0
Flink 1.20.2
Paimon 1.0.1
Flink-dokcer dev-1.20
Reporter: hunter
Attachments: image-2025-09-15-11-19-47-985.png,
image-2025-09-15-11-20-41-428.png, image-2025-09-15-11-22-09-179.png
The following type conversion problem occurs at the beginning.
{code:java}
org.apache.flink.streaming.runtime.tasks.StreamTaskException: Could not
instantiate serializer. at
org.apache.flink.streaming.api.graph.StreamConfig.getTypeSerializerOut(StreamConfig.java:311)
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.createStreamOutput(OperatorChain.java:553)
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.createChainOutputs(OperatorChain.java:523)
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.<init>(OperatorChain.java:191)
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.<init>(RegularOperatorChain.java:60)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:789)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:771)
at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:970)
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:939)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:763) at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) at
java.base/java.lang.Thread.run(Unknown Source) Caused by:
java.lang.ClassCastException: cannot assign instance of
java.lang.invoke.SerializedLambda to field
org.apache.flink.streaming.api.connector.sink2.CommittableMessageTypeInfo.committableSerializerFactory
of type org.apache.flink.util.function.SerializableSupplier in instance of
org.apache.flink.streaming.api.connector.sink2.CommittableMessageTypeInfo at
java.base/java.io.ObjectStreamClass$FieldReflector.setObjFieldValues(Unknown
Source) at
java.base/java.io.ObjectStreamClass$FieldReflector.checkObjectFieldValueTypes(Unknown
Source) at java.base/java.io.ObjectStreamClass.checkObjFieldValueTypes(Unknown
Source) at java.base/java.io.ObjectInputStream.defaultCheckFieldValues(Unknown
Source) at java.base/java.io.ObjectInputStream.readSerialData(Unknown Source)
at java.base/java.io.ObjectInputStream.readOrdinaryObject(Unknown Source) at
java.base/java.io.ObjectInputStream.readObject0(Unknown Source) at
java.base/java.io.ObjectInputStream.readArray(Unknown Source) at
java.base/java.io.ObjectInputStream.readObject0(Unknown Source) at
java.base/java.io.ObjectInputStream.defaultReadFields(Unknown Source) at
java.base/java.io.ObjectInputStream.readSerialData(Unknown Source) at
java.base/java.io.ObjectInputStream.readOrdinaryObject(Unknown Source) at
java.base/java.io.ObjectInputStream.readObject0(Unknown Source) at
java.base/java.io.ObjectInputStream.defaultReadFields(Unknown Source) at
java.base/java.io.ObjectInputStream.readSerialData(Unknown Source) at
java.base/java.io.ObjectInputStream.readOrdinaryObject(Unknown Source) at
java.base/java.io.ObjectInputStream.readObject0(Unknown Source) at
java.base/java.io.ObjectInputStream.readObject(Unknown Source) at
java.base/java.io.ObjectInputStream.readObject(Unknown Source) at
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:488)
at
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:472)
at
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:467)
at
org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:422)
at
org.apache.flink.streaming.api.graph.StreamConfig.getTypeSerializerOut(StreamConfig.java:309)
... 11 more {code}
Then modify java.lang.invoke.SerializedLambda to create it through new
!image-2025-09-15-11-19-47-985.png!
!image-2025-09-15-11-22-09-179.png!
Then report an error again
!image-2025-09-15-11-20-41-428.png!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
