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 <u...@apache.org>:
> 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
> <y.marzou...@mindlytix.com> wrote:
> > 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 command doesn't execute and
> keeps
> > waiting for input. If I hit enter again I get the following error from
> > Environment.py : ValueError("Invalid mode specified: " + mode)
> > Looking at the source code, it looks like there are a bunch of
> > sys.stdin.readline().rstrip('\n') where an input is expected from the
> user.
> > Any idea how to run the job? Thank you.
> >
> > Best,
> > Yassine
> >
>
