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

[Гость]

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

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

    

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 

My jar file is getting successfully build. These are the contents of my 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

On submitting my job jar file to Apache Flink Dashboard, i am getting server error with this-

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

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

Where am I going wrong? Please keep in mind that I am just starting with Flink and am learning.


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