Flink: ошибка при запуске программы flink на CLI - PullRequest
Новая
       12

Flink: ошибка при запуске программы flink на CLI

0 голосов
/ 28 февраля 2020

Я пытаюсь запустить программу обработки паром, которая использует разъем kafka (последний универсальный разъем). Задания выполняются без проблем на IntelliJ, но когда я отправляю код, встроенный в jar с использованием пакета sbt, выдает ошибку ниже. java .lang.ClassNotFoundException: org. apache .flink.streaming.connectors.kafka.FlinkKafkaConsumerBase

Я также использовал банку, созданную с использованием традиционной опции IntellIJ, но все же я получаю Выше ошибка.

1 Ответ

1 голос
/ 28 февраля 2020

Скорее всего, проблема в том, что вы не включили зависимости в файл JAR. Зависимости коннектора не включены в двоичный файл Flink. Как правило, предпочтительным способом решения этой проблемы является использование подходящего плагина для Вашего инструмента сборки, например shade-plugin для Maven или assembly для sbt, для создания так называемого fat-jar, то есть JAR с включенными зависимостями.

...