You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Kyle Weaver (Jira)" <ji...@apache.org> on 2019/10/30 21:26:00 UTC
[jira] [Created] (BEAM-8522)
beam_PreCommit_Python2_PVR_Flink_Commit failure
Kyle Weaver created BEAM-8522:
---------------------------------
Summary: beam_PreCommit_Python2_PVR_Flink_Commit failure
Key: BEAM-8522
URL: https://issues.apache.org/jira/browse/BEAM-8522
Project: Beam
Issue Type: Bug
Components: runner-flink
Reporter: Kyle Weaver
I'm confused by why this happens, as we added flink-master-url as an alias for flink-master.
*14:02:09* [main] ERROR org.apache.beam.runners.flink.FlinkJobServerDriver - Unable to parse command line arguments.*14:02:09* org.kohsuke.args4j.CmdLineException: "--flink-master-url" is not a valid option*14:02:09* at org.kohsuke.args4j.CmdLineParser.parseArgument(CmdLineParser.java:497)*14:02:09* at org.apache.beam.runners.flink.FlinkJobServerDriver.parseArgs(FlinkJobServerDriver.java:87)*14:02:09* at org.apache.beam.runners.flink.FlinkJobServerDriver.fromParams(FlinkJobServerDriver.java:98)*14:02:09* at org.apache.beam.runners.flink.FlinkJobServerDriver.main(FlinkJobServerDriver.java:73)*14:02:09* Usage: java FlinkJobServerDriver arguments...*14:02:09* --artifact-port N : The artifact service port. 0 to use a*14:02:09* dynamic port. (Default: 8098) (default: 8098)*14:02:09* --artifacts-dir VAL : The location to store staged artifact files*14:02:09* (default: /tmp/beam-artifact-staging)*14:02:09* --clean-artifacts-per-job VALUE : When true, remove each job's staged*14:02:09* artifacts when it completes (default: true)*14:02:09* --expansion-port N : The Java expansion service port. 0 to use a*14:02:09* dynamic port. (Default: 8097) (default: 8097)*14:02:09* --flink-conf-dir VAL : Directory containing Flink YAML*14:02:09* configuration files. These properties will*14:02:09* be set to all jobs submitted to Flink and*14:02:09* take precedence over configurations in*14:02:09* FLINK_CONF_DIR.*14:02:09* --flink-master VAL : Flink master address (host:port) to submit*14:02:09* the job against. Use Use "[local]" to start*14:02:09* a local cluster for the execution. Use*14:02:09* "[auto]" if you plan to either execute*14:02:09* locally or submit through Flink's CLI.*14:02:09* (default: [auto])*14:02:09* --job-host VAL : The job server host name (default: localhost)*14:02:09* --job-port N : The job service port. 0 to use a dynamic*14:02:09* port. (Default: 8099) (default: 8099)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)