你的报错是在Client端还是JM端呢，client/JM的日志以及启动命令最好可以发一下吧 这样方便查问题
Application和Perjob模式本质上的区别是用户main运行的位置不一样，所以会导致JM启动的classpath 也不太一样的 Best, Yang Hito Zhu <[email protected]> 于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/ >
