Thanks for sharing! Great to hear! On Wed, Nov 24, 2021 at 3:59 AM Kamil ty <kamilt...@gmail.com> wrote:
> 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 >>>> >>>