D:\apps\flink-1.9.0>start "flink cluster" .\bin\start-cluster.bat
Run command line to execute a java application
D:\apps\flink-1.9.0>.\bin\flink.bat run -c org.rssnews.flink.RSSFlinkApp d:\dvp\rssnews\rss-flink\target\flink-0.0.1-SNAPSHOT.jar
log4j:WARN No appenders could be found for logger (org.apache.flink.client.cli.CliFrontend).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
------------------------------------------------------------
The program finished with the following exception:
java.lang.RuntimeException: Could not look up the main(String[]) method from the class org.rssnews.flink.RSSFlinkApp: org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer09
at org.apache.flink.client.program.PackagedProgram.hasMainMethod(PackagedProgram.java:546)
at org.apache.flink.client.program.PackagedProgram.
at org.apache.flink.client.cli.CliFrontend.buildProgram(CliFrontend.java:799)
at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:196)
at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1010)
at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1083)
at org.apache.flink.runtime.security.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30)
at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1083)
Caused by: java.lang.NoClassDefFoundError: org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer09
at java.lang.Class.getDeclaredMethods0(Native Method)
at java.lang.Class.privateGetDeclaredMethods(Unknown Source)
at java.lang.Class.privateGetMethodRecursive(Unknown Source)
at java.lang.Class.getMethod0(Unknown Source)
at java.lang.Class.getMethod(Unknown Source)
at org.apache.flink.client.program.PackagedProgram.hasMainMethod(PackagedProgram.java:540)
... 7 more
Caused by: java.lang.ClassNotFoundException: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09
at java.net.URLClassLoader.findClass(Unknown Source)
at java.lang.ClassLoader.loadClass(Unknown Source)
at java.lang.ClassLoader.loadClass(Unknown Source)
... 13 more
D:\apps\flink-1.9.0>
1 comment:
That was missing
environment.execute();
Post a Comment