Run a Flink job: REST/ binary client

[Flavio Pompermaier]

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

[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 <[hidden email]> 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

[Timo Walther]

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 <[hidden email]> 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