flink的实施报错cannot assign instance of org.apache.commons.collections.map.LinkedMap to field com.verver

报错信息本质原因解决方式官方文档

cannot assign instance of 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

linkedMap class is being loaded from two different packages, and those are being assigned to each other.

在/opt/flink-1.13.6/conf/flink-conf.yaml 添加如下内容并重启 flink.

classloader.resolve-order: parent-first

https://ci.apache.org/projects/flink/flink-docs-release-1.8/monitoring/debugging_classloading.html