You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Flavio Pompermaier <po...@okkam.it> on 2018/11/06 15:55:25 UTC

Run a Flink job: REST/ binary client

Hi to all,
I'm using Flink 1.3.2. If executing a job using bin/flink run everything
goes well.
If executing using REST service of job manager (/jars:jarid/run) the job
writes to the sink but fails to return on env.execute() and all the code
after it is not executed.

Is this a known issue? Was it resolved in Flink 1.6.2?

Best,
Flavio

Re: Run a Flink job: REST/ binary client

Posted by Timo Walther <tw...@apache.org>.
I will loop in Chesnay. He might know more about the REST service internals.

Timo

Am 07.11.18 um 16:15 schrieb Flavio Pompermaier:
> After a painful migration to Flink 1.6.2 we were able to run one of 
> the jobs.
> Unfortunately we faced the same behaviour: all the code after the 
> first env.execute() is not execute if the job is called from the REST 
> services or from the web UI, while everything works fine if running 
> the job using 'bin/flink run' from a shell.
>
> Any solution to this?
>
> On Tue, Nov 6, 2018 at 4:55 PM Flavio Pompermaier 
> <pompermaier@okkam.it <ma...@okkam.it>> wrote:
>
>     Hi to all,
>     I'm using Flink 1.3.2. If executing a job using bin/flink run
>     everything goes well.
>     If executing using REST service of job manager (/jars:jarid/run)
>     the job writes to the sink but fails to return on env.execute()
>     and all the code after it is not executed.
>
>     Is this a known issue? Was it resolved in Flink 1.6.2?
>
>     Best,
>     Flavio
>
>

Re: Run a Flink job: REST/ binary client

Posted by Flavio Pompermaier <po...@okkam.it>.
After a painful migration to Flink 1.6.2 we were able to run one of the
jobs.
Unfortunately we faced the same behaviour: all the code after the first
env.execute() is not execute if the job is called from the REST services or
from the web UI, while everything works fine if running the job using
'bin/flink run' from a shell.

Any solution to this?

On Tue, Nov 6, 2018 at 4:55 PM Flavio Pompermaier <po...@okkam.it>
wrote:

> Hi to all,
> I'm using Flink 1.3.2. If executing a job using bin/flink run everything
> goes well.
> If executing using REST service of job manager (/jars:jarid/run) the job
> writes to the sink but fails to return on env.execute() and all the code
> after it is not executed.
>
> Is this a known issue? Was it resolved in Flink 1.6.2?
>
> Best,
> Flavio
>