tttzzzwww commented on PR #2501:
URL: https://github.com/apache/flink-cdc/pull/2501#issuecomment-2431653271
针对此问题，我研究了一天，按照上述流程，按他要求生成了jar包，任务可以正常提交，但提交任务给我来：
`Caused by: java.lang.ClassCastException: cannot assign instance of
com.ververica.cdc.connectors.shaded.org.apache.commons.collections.map.LinkedMap
to field
com.ververica.cdc.debezium.DebeziumSourceFunction.pendingOffsetsToCommit of
type org.apache.commons.collections.map.LinkedMap in instance of
com.ververica.cdc.debezium.DebeziumSourceFunction
at
java.base/java.io.ObjectStreamClass$FieldReflector.setObjFieldValues(ObjectStreamClass.java:2205)
at
java.base/java.io.ObjectStreamClass$FieldReflector.checkObjectFieldValueTypes(ObjectStreamClass.java:2168)
at
java.base/java.io.ObjectStreamClass.checkObjFieldValueTypes(ObjectStreamClass.java:1422)
at
java.base/java.io.ObjectInputStream.defaultCheckFieldValues(ObjectInputStream.java:2450)
at
java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2357)
at
java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2166)
at
java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1668)
at
java.base/java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2434)
at
java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2328)
at
java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2166)
at
java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1668)
at
java.base/java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2434)
at
java.base/java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2328)
at
java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2166)
at
java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1668)
at
java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:482)
at
java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:440)
at
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:617)
at
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:602)
at
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:589)
at
org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:543)
at
org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:383)
... 9 more`
给我整无语了，然后我将关于org.apache.commons.collections相关配置的relocation去掉，重新生成jar包，结果生成的jar引用：import
org.apache.commons.collections.map.LinkedMap; 正确了 .......
不知道是不是org.apache.maven.plugins的问题，可能是缓存导致的.....
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
