Hi Hao, Vino is right, you need to specify the -j/--job-classname option which specifies the job name you want to execute. Please make sure that the jar containing this class is on the class path.
I recently pushed some fixes which generate a better error message than the one you've received. If you check out the latest master branch, then it should work better. Let me know if you should run into other problems. Cheers, Till On Sat, Aug 25, 2018 at 5:11 AM Hao Sun <ha...@zendesk.com> wrote: > Thanks, I'll look into it. > > On Fri, Aug 24, 2018, 19:44 vino yang <yanghua1...@gmail.com> wrote: > >> 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) >>> >>
