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
>>>>
>>>

Reply via email to