我试图运行一个flink蒸汽程序，使用Kafka连接器（最新的通用连接器）。作业在intellij上运行没有任何问题，但是当我使用sbt包将代码提交到jar中时，出现了以下错误。java.lang.classnotfoundexception:org.apache.flink.streaming.connectors.kafka.flinkkafcumerbase
我还使用了使用传统intellij选项构建的jar，但仍然得到了上面的错误。
我试图运行一个flink蒸汽程序，使用Kafka连接器（最新的通用连接器）。作业在intellij上运行没有任何问题，但是当我使用sbt包将代码提交到jar中时，出现了以下错误。java.lang.classnotfoundexception:org.apache.flink.streaming.connectors.kafka.flinkkafcumerbase
我还使用了使用传统intellij选项构建的jar，但仍然得到了上面的错误。
1条答案
按热度按时间oaxa6hgo1#
最可能的问题是您没有在jar文件中包含依赖项。flink二进制文件中不包括连接器依赖项。一般来说，解决这个问题的首选方法是为构建工具使用合适的插件，比如
shade-plugin对于maven或assembly让sbt创建所谓的fatjar，即包含依赖项的jar。