【Flink】Flink SQL Cannot instantiate user function cannot assign instance LinkedMap FlinkKafkaConsum

【Flink】Flink SQL Cannot instantiate user function cannot assign instance LinkedMap FlinkKafkaConsum

文章目录

1.场景1

1.1 概述 1.2 源码解析

1.场景1 1.1 概述

写了一个flink程序，然后运行报错如下。

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

程序如下

package P1;