java ClassNotFoundException:org。阿帕奇。弗林克。流动。连接器。兔子。常见的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 run-c com。我的公司。App~/。m2/repository/com/mycompany/flinker/1.0-SNAPSHOT/flinker-1.0-SNAPSHOT。罐子

Answer 1

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

Documentation