Thank you Matthias and Dian! I have verified this command: bin/flink run -py examples/python/table/batch/word_count.py --test "Hello World" Where the "--test" argument is accessed from the python code, and the arguments work as expected.
Best regards Kamil On Tue, 23 Nov 2021 at 02:48, Dian Fu <dian0511...@gmail.com> wrote: > Hi Kamil, > > It's documented at the end of the page: > https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/cli/#submitting-pyflink-jobs > . > > Regards, > Dian > > On Tue, Nov 23, 2021 at 12:10 AM Matthias Pohl <matth...@ververica.com> > wrote: > >> Hi Kamil, >> afaik, the parameter passing should work as normal by just appending them >> to the Flink job submission similar to the Java job submission: >> ``` >> $ ./flink run --help >> Action "run" compiles and runs a program. >> Syntax: run [OPTIONS] <jar-file> <arguments> >> [...] >> ``` >> >> Matthias >> >> On Mon, Nov 22, 2021 at 3:58 PM Kamil ty <kamilt...@gmail.com> wrote: >> >>> Hey, >>> >>> Looking at the examples at Command-Line Interface | Apache Flink >>> <https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/cli/> >>> I >>> don't see an example of passing command line arguments to a pyflink job >>> when deploying the job to a remote cluster with flink cli. Is this >>> supported? >>> >>> Best Regards >>> Kamil >>> >>
