时间戳

首页 > 解决方案 > Flink：在 CLI 上运行 flink 程序时出错

apache-flink - Flink：在 CLI 上运行 flink 程序时出错

问题描述

我正在尝试运行一个使用 kafka 连接器（最新的通用连接器）的 flink 蒸汽程序。这些作业在 IntelliJ 上运行没有任何问题，但是当我使用 sbt 包将代码构建到 jar 中时，出现以下错误。 java.lang.ClassNotFoundException: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase

我还使用了使用传统 IntellIJ 选项构建的 jar，但仍然出现上述错误。

标签： apache-flinkflink-streaming

解决方案

最有可能的问题是您没有在您的 JAR 文件中包含依赖项。Flink 二进制文件中不包含连接器依赖项。通常，解决此问题的首选方法是为您的构建工具（如shade-pluginMaven 或assemblysbt）使用适当的插件来创建所谓的 fat-jar，即包含依赖项的 JAR。

推荐阅读