1.场景1
1.1 概述
1.2 源码解析
写了一个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;



