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 r
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
'bi
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()
