Thanks Dian! That worked !
On Sun, Mar 6, 2022 at 10:47 PM Dian Fu wrote:
> The dedicated REST API is still not supported. However, you could try to
> use PythonDriver just like you said and just submit it like a Java Flink
> job.
>
> Regards,
> Dian
>
> On Sun, Mar 6, 2022 at 3:38 AM aryan m w
The dedicated REST API is still not supported. However, you could try to
use PythonDriver just like you said and just submit it like a Java Flink
job.
Regards,
Dian
On Sun, Mar 6, 2022 at 3:38 AM aryan m wrote:
> Thanks Zhilong for taking a look!
>
> Primarily I am looking for ways to start it
Thanks Zhilong for taking a look!
Primarily I am looking for ways to start it through a REST api [1] . For
Java, I pass along entry-class pointing to a main class in the jar which
constructs the job graph and triggers the execute(). How do we accomplish
this for pyflink jobs? The closest I enco
Hi, Aryan:
You could refer to the official docs [1] for how to submit PyFlink jobs.
$ ./bin/flink run \
--target yarn-per-job
--python examples/python/table/word_count.py
With this command you can submit a per-job application to YARN. The docs
[2] and [3] describe how to submit jobs
