Re: Execute PyFlink jobs: flink-python module seems to be missing or not working

2021-10-28 Thread Dian Fu
rks fine. > > > > Regards, > > Christian > > > > > > *Von:* Dian Fu > *Gesendet:* Donnerstag, 28. Oktober 2021 10:21 > *An:* Schmid Christian > *Cc:* user@flink.apache.org > *Betreff:* Re: Execute PyFlink jobs: flink-python module seems to be > missin

AW: Execute PyFlink jobs: flink-python module seems to be missing or not working

2021-10-28 Thread Schmid Christian
Cc: user@flink.apache.org Betreff: Re: Execute PyFlink jobs: flink-python module seems to be missing or not working Hi Schmid, Just as you have seen that the jar package of flink-python is located in the directory $FLINK_HOME/opt. It seems that this jar doesn't exist in your environment. Could y

Re: Execute PyFlink jobs: flink-python module seems to be missing or not working

2021-10-28 Thread Dian Fu
Hi Schmid, Just as you have seen that the jar package of flink-python is located in the directory $FLINK_HOME/opt. It seems that this jar doesn't exist in your environment. Could you double check that? Regards, Dian On Thu, Oct 28, 2021 at 3:35 PM Schmid Christian wrote: > Hi, > > > > When I e

Execute PyFlink jobs: flink-python module seems to be missing or not working

2021-10-28 Thread Schmid Christian
Hi, When I execute a PyFlink-Job locally in a mini cluster, then everything works fine: (env) user@bla /cygdrive/c/flink1_13_3/examples/python/table/batch $ python word_count.py Results directory: C:\cygwin64\tmp/result But when I try to execute the PyFlink-Job in a remote cluster, the job exe