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;
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)