Ok, thank you!
On Sat, 29 Aug, 2020, 4:07 pm Xingbo Huang, wrote:
> Hi Manas,
>
> We can't submit a pyflink job through flink web currently. The only way
> currently to submit a pyFlink job is through the command line.
>
> Best,
> Xingbo
>
> Manas Kale 于2020年8月29日周六 下午12:51写道：
>
>> Hi Xingbo,
Hi Manas,
We can't submit a pyflink job through flink web currently. The only way
currently to submit a pyFlink job is through the command line.
Best,
Xingbo
Manas Kale 于2020年8月29日周六 下午12:51写道：
> Hi Xingbo,
> Thanks, that worked. Just to make sure, the only way currently to submit a
> pyFlink
Hi Xingbo,
Thanks, that worked. Just to make sure, the only way currently to submit a
pyFlink job is through the command line right? Can I do that through the
GUI?
On Fri, Aug 28, 2020 at 8:17 PM Xingbo Huang wrote:
> Hi Manas,
>
> I think you forgot to add kafka jar[1] dependency. You can use
Hi Manas,
I think you forgot to add kafka jar[1] dependency. You can use the argument
-j of the command line[2] or the Python Table API to specify the jar. For
details about the APIs of adding Java dependency, you can refer to the
relevant documentation[3]
[1]
Hi,
I am trying to deploy a pyFlink application on a local cluster. I am able
to run my application without any problems if I execute it as a normal
python program using the command :
python myApplication.py
My pyFlink version is __version__ = "1.11.0".
I had installed this pyFlink through
