Thanks Till for the follow up, I can run my job now. On Tue, Aug 28, 2018, 00:57 Till Rohrmann <trohrm...@apache.org> wrote:
> 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 >>> <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 >>> <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) >>>> >>>
