开发者社区> 问答> 正文

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

我把作业提交模式从 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 下正常运行,请各位帮忙看下。

*来自志愿者整理的flink邮件归档

展开
收起
小阿矿 2021-12-06 15:12:56 1171 0
1 条回答
写回答
取消 提交回答
  • Application和Perjob模式本质上的区别是用户main运行的位置不一样,所以会导致JM启动的classpath

    也不太一样的

    *来自志愿者整理的flink邮件归档

    2021-12-06 16:57:53
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载