Org.apache.flink.client.program.ProgramInvoctionException: класс точки входа программы не удалось загрузить из-за сбоя п ⇐ JAVA

[Гость]

Я пытаюсь отправить базовое задание flink на свою веб-панель управления Apache Flink (localhost:8081). Это мой пом-

Код: Выделить всё

    
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0

com.flink
kafkaconsumer
1.0-SNAPSHOT


17
17
1.8



org.apache.flink
flink-clients
1.15.1
provided






org.apache.maven.plugins
maven-shade-plugin
3.1.1



package

shade


false


org.apache.flink:flink-shaded-force-shading
org.slf4j:*
org.apache.logging.log4j:*





*:*

META-INF/*.SF
META-INF/*.DSA
META-INF/*.RSA






 com.flink.KafkaConsumer 

Мой jar-файл успешно собирается. Вот содержимое моей банки -

Код: Выделить всё

META-INF/MANIFEST.MF
META-INF/
com/
com/flink/
com/flink/KafkaConsumer.class
com/flink/Main.class
META-INF/maven/
META-INF/maven/com.flink/
META-INF/maven/com.flink/kafkaconsumer/
META-INF/maven/com.flink/kafkaconsumer/pom.xml
META-INF/maven/com.flink/kafkaconsumer/pom.properties

При отправке JAR-файла задания на панель управления Apache Flink я получаю сообщение об ошибке сервера:

Код: Выделить всё

org.apache.flink.client.program.ProgramInvocationException: The program's entry point class 'com.flink.KafkaConsumer' could not be loaded due to a linkage failure.

Где я ошибаюсь? Имейте в виду, что я только начинаю работать с Flink и учусь.

Источник: https://stackoverflow.com/questions/781 ... rams-entry