Thursday, October 17, 2019

Run Flink in windows

Start up the server

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.(PackagedProgram.java:234)
        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:

Alex said...

That was missing

environment.execute();