Flink生产问题记录
1.集群有2个flink版本,用application方式启动报错
Caused by: java.lang.ClassCastException: cannot assign instance of org.apache.commons.collections.map.LinkedMap to field org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.pendingOffsetsToCommit of type org.apache.commons.collections.map.LinkedMap in instance of org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer
- 原因分析：
LinkedMap class is being loaded from two different packages, and those are being assigned to each other. - 解决：在配置文件里添加
classloader.resolve-order: parent-first