You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Yassine MARZOUGUI <y....@mindlytix.com> on 2018/01/04 10:08:01 UTC
Re: Python API not working
Hi all,
Any ideas on this?
2017-12-15 15:10 GMT+01:00 Yassine MARZOUGUI <y....@mindlytix.com>:
> 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 <uc...@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....@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
>> >
>>
>
>
Re: Python API not working
Posted by Chesnay Schepler <ch...@apache.org>.
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?
>
>
> 2017-12-15 15:10 GMT+01:00 Yassine MARZOUGUI
> <y.marzougui@mindlytix.com <ma...@mindlytix.com>>:
>
> 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 <uce@apache.org
> <ma...@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.marzougui@mindlytix.com <ma...@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
> >
>
>
>