flink 踩坑之旅
·
1.Flink 提交任务 java.lang.ClassCastException LinkedMap
解决方法 在flink-yarn.yaml配置文件增加 classloader.resolve-order:(空格)parent-first
注意:需要增加在:和值之间增加空格
2.java.lang.IllegalAccessError: tried to access method org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.adjustAutoCommitConfig
kafka版本的冲突
更多推荐
所有评论(0)