ClassNotFoundException: org.apache.flink.streaming.connectors.rabbitmq.common.RMQConnectionConfig $ Builder - PullRequest
Новая
       48

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

0 голосов
/ 06 ноября 2019

Я использую 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 / репозиторий / com / mycompany / flinker / 1.0-SNAPSHOT / flinker-1.0-SNAPSHOT.jar

1 Ответ

1 голос
/ 06 ноября 2019

Похоже, среда выполнения Flink не находит flink-connector-rabbitmq_2.11-1.9.0.jar. Вам нужно либо упаковать свой код и любые зависимости (включая эту) в jar-файл uber, либо скопировать jink-файл flink / rabbitmq в каталог lib всех машин в кластере.

Документация

...