You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by Hito Zhu <qr...@gmail.com> on 2020/07/16 08:05:10 UTC

flink1.11 Application 模式下启动失败问题

Hi all
我把作业提交模式从 yarn-cluster 换成 application 模式，启动失败，报两个错误：
1、java.lang.ClassNotFoundException:
org.apache.hadoop.yarn.api.records.ResourceInformation
2、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
com.tydic.tysc.core.flink.cal.v3.core.connector.kafka.source.KafkaTableSource$CustomerFlinkKafkaConsumer
在 yarn-cluster 下正常运行，请各位帮忙看下。



--
Sent from: http://apache-flink.147419.n8.nabble.com/