classnotfoundexception:org.apache.flink.streaming.connectors.rabbitmq.common.rmqconnectionconfig$builder

0tdrvxhp 于 2021-06-24 发布在 Flink

关注(0)|答案(1)|浏览(337)

我使用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.mycompany.app~/.m2/repository/com/mycompany/flinker/1.0-snapshot/flinker-1.0-snapshot.jar

Java apache-flink flink-streaming rabbitmq

来源：https://stackoverflow.com/questions/58725944/classnotfoundexception-org-apache-flink-streaming-connectors-rabbitmq-common-rm