Re: Python API not working

2018-01-08 Thread Chesnay Schepler
You can't run the python script directly, instead it must be submitted to a flink cluster using the pyflink.sh script, as described in the documentation, which will in turn call the script with the appropriate parameters. On 04.01.2018 11:08, Yassine MARZOUGUI wrote: Hi all, Any ideas on this

Re: Python API not working

2018-01-04 Thread Yassine MARZOUGUI
Hi all, Any ideas on this? 2017-12-15 15:10 GMT+01:00 Yassine MARZOUGUI : > Hi Ufuk, > > Thanks for your response. Unfortunately specifying 'streaming` or `batch` > doesn't work, it looks like mode should be either "plan" or "operator" , > and then the program expects other inputs from the stdi

Re: Python API not working

2017-12-15 Thread Yassine MARZOUGUI
Hi Ufuk, Thanks for your response. Unfortunately specifying 'streaming` or `batch` doesn't work, it looks like mode should be either "plan" or "operator" , and then the program expects other inputs from the stdin (id, port, etc.). 2017-12-15 14:23 GMT+01:00 Ufuk Celebi : > Hey Yassine, > > let m

Re: Python API not working

2017-12-15 Thread Ufuk Celebi
Hey Yassine, let me include Chesnay (cc'd) who worked on the Python API. I'm not familiar with the API and what it expects, but try entering `streaming` or `batch` for the mode. Chesnay probably has the details. – Ufuk On Fri, Dec 15, 2017 at 11:05 AM, Yassine MARZOUGUI wrote: > Hi All, > > I

Python API not working

2017-12-15 Thread Yassine MARZOUGUI
Hi All, I'm trying to use Flink with the python API, and started with the wordcount exemple from the Documentation. I'm using Flink 1.4 and python 2.7. When running env.execute(local=True), the comm