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

[Hito Zhu]

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/

[Yang Wang]

你的报错是在Client端还是JM端呢，client/JM的日志以及启动命令最好可以发一下吧
这样方便查问题


Application和Perjob模式本质上的区别是用户main运行的位置不一样，所以会导致JM启动的classpath
也不太一样的


Best,
Yang

Hito Zhu <[hidden email]> 于2020年7月16日周四 下午4:26写道：

> 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/
>