我使用flink 1.9.0和rabbitmqconnector读取数据,我可以成功编译我的代码,但当我运行代码时,我会收到以下错误:
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.mycompany.App ~/.m2/repository.com/mycompany/flinker/1.0-SNAPSHOT/flinker-1.0-SNAPSHOT.jar
听起来Flink运行时找不到Flink-connector-rabbitmq_2.11-1.9.0.jar。您需要将代码和任何依赖项(包括此依赖项(打包到一个uber jar中,或者将Flink/rabbitmqjar复制到集群中所有机器的lib目录中。
文档