Hi Hao Sun, >From the error log, it seems that the jar package for the job was not found. You must make sure your Jar is in the classpath. Related documentation may not be up-to-date, and there is a discussion on this issue on this mailing list. [1]
I see that the status of FLINK-10001 [2] is closed and it will be updated with the release of 1.6.1 and 1.7.0. [1]: http://mail-archives.apache.org/mod_mbox/flink-dev/201808.mbox/%3CCAC27z=OaohMbmcryB-+m3GBmZP=xpha8mihv7zs1grgsekk...@mail.gmail.com%3E [2]: https://issues.apache.org/jira/browse/FLINK-10001 Thanks, vino. Hao Sun <ha...@zendesk.com> 于2018年8月25日周六 上午6:37写道： > I got an error like this. > > $ docker run -it flink-job:latest job-cluster > Starting the job-cluster > config file: > jobmanager.rpc.address: localhost > jobmanager.rpc.port: 6123 > jobmanager.heap.size: 1024m > taskmanager.heap.size: 1024m > taskmanager.numberOfTaskSlots: 1 > parallelism.default: 1 > rest.port: 8081 > Starting standalonejob as a console application on host cf9bd047082c. > 2018-08-24 22:33:00,773 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint - > -------------------------------------------------------------------------------- > 2018-08-24 22:33:00,774 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Starting > StandaloneJobClusterEntryPoint (Version: 1.6.0, Rev:ff472b4, > Date:07.08.2018 @ 13:31:13 UTC) > 2018-08-24 22:33:00,775 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint - OS current user: > flink > 2018-08-24 22:33:01,168 WARN org.apache.hadoop.util.NativeCodeLoader - > Unable to load native-hadoop library for your platform... using > builtin-java classes where applicable > 2018-08-24 22:33:01,232 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Current > Hadoop/Kerberos user: flink > 2018-08-24 22:33:01,232 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint - JVM: OpenJDK 64-Bit > Server VM - Oracle Corporation - 1.8/25.111-b14 > 2018-08-24 22:33:01,232 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Maximum heap size: > 981 MiBytes > 2018-08-24 22:33:01,232 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint - JAVA_HOME: > /usr/lib/jvm/java-1.8-openjdk/jre > 2018-08-24 22:33:01,236 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Hadoop version: > 2.8.3 > 2018-08-24 22:33:01,236 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint - JVM Options: > 2018-08-24 22:33:01,236 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Xms1024m > 2018-08-24 22:33:01,236 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Xmx1024m > 2018-08-24 22:33:01,237 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint - > -Dlog4j.configuration=file:/opt/flink-1.6.0/conf/log4j-console.properties > 2018-08-24 22:33:01,237 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint - > -Dlogback.configurationFile=file:/opt/flink-1.6.0/conf/logback-console.xml > 2018-08-24 22:33:01,237 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Program Arguments: > 2018-08-24 22:33:01,237 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint - --configDir > 2018-08-24 22:33:01,238 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint - > /opt/flink-1.6.0/conf > 2018-08-24 22:33:01,238 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Classpath: > /opt/flink-1.6.0/lib/flink-python_2.11-1.6.0.jar:/opt/flink-1.6.0/lib/flink-shaded-hadoop2-uber-1.6.0.jar:/opt/flink-1.6.0/lib/job.jar:/opt/flink-1.6.0/lib/log4j-1.2.17.jar:/opt/flink-1.6.0/lib/slf4j-log4j12-1.7.7.jar:/opt/flink-1.6.0/lib/flink-dist_2.11-1.6.0.jar::: > 2018-08-24 22:33:01,238 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint - > -------------------------------------------------------------------------------- > 2018-08-24 22:33:01,240 INFO > org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Registered UNIX > signal handlers for [TERM, HUP, INT] > 2018-08-24 22:33:01,248 ERROR > *org.apache.flink.runtime.entrypoint.ClusterEntrypoint > - Could not parse command line arguments [--configDir, > /opt/flink-1.6.0/conf].* > org.apache.flink.runtime.entrypoint.FlinkParseException: Failed to parse > the command line arguments. > at > org.apache.flink.runtime.entrypoint.parser.CommandLineParser.parse(CommandLineParser.java:52) > at > org.apache.flink.container.entrypoint.StandaloneJobClusterEntryPoint.main(StandaloneJobClusterEntryPoint.java:143) > Caused by: org.apache.commons.cli.MissingOptionException: *Missing > required option: j* > at > org.apache.commons.cli.DefaultParser.checkRequiredOptions(DefaultParser.java:199) > at org.apache.commons.cli.DefaultParser.parse(DefaultParser.java:130) > at org.apache.commons.cli.DefaultParser.parse(DefaultParser.java:81) > at > org.apache.flink.runtime.entrypoint.parser.CommandLineParser.parse(CommandLineParser.java:50) > ... 1 more > Exception in thread "main" java.lang.IllegalArgumentException: > cmdLineSyntax not provided > at org.apache.commons.cli.HelpFormatter.printHelp(HelpFormatter.java:546) > at org.apache.commons.cli.HelpFormatter.printHelp(HelpFormatter.java:492) > at org.apache.commons.cli.HelpFormatter.printHelp(HelpFormatter.java:408) > at > org.apache.flink.runtime.entrypoint.parser.CommandLineParser.printHelp(CommandLineParser.java:60) > at > org.apache.flink.container.entrypoint.StandaloneJobClusterEntryPoint.main(StandaloneJobClusterEntryPoint.java:146) >
