ClassNotFoundException：org.apache.flink.streaming.connectors.rabbitmq.common.RMQConnectionConfig $ Builder

Question

我正在使用flink 1.9.0和Rabbitmq连接器读取数据，我可以成功编译代码，但是当我运行代码时，出现以下错误：

java.lang.NoClassDefFoundError: org/apache/flink/streaming/connectors/rabbitmq/common/RMQConnectionConfig$Builder

我在pom文件中没有为依赖项定义任何范围。

final RMQConnectionConfig connectionConfig = new RMQConnectionConfig.Builder().setHost("myhost.com").setPort(1234).setUserName("username").setPassword("password").setVirtualHost("/").build();

我正在尝试在本地运行flink服务器，因此首先我启动flink群集，然后运行以下命令。

../ bin / flink运行-c com.mycompany.App〜/ .m2 / repository / com / mycompany / flinker / 1.0-SNAPSHOT / flinker-1.0-SNAPSHOT.jar

Answer 1

听起来Flink运行时找不到flink-connector-rabbitmq_2.11-1.9.0.jar。您需要将代码和任何依赖项（包括此依赖项）打包到一个uber jar中，或者将flink / rabbitmq jar复制到集群中所有计算机的lib目录中。

Documentation