Thanks a lot for the clarification.
On Tue, Jun 4, 2019 at 8:37 AM Yun Gao wrote:
> Hi Debasish,
>
> You cannot get ExecutionGraph since it resides in the JobMaster,
> which is not in the same process with Client.
>
> In my opinion, currently you may not be able to stop the job or quer
Hi Debasish,
You cannot get ExecutionGraph since it resides in the JobMaster, which is
not in the same process with Client.
In my opinion, currently you may not be able to stop the job or query the
job status using the Client API. The community is currently trying to enhance
the Clie
Hello -
I am trying to build an API that can start, control and stop a Flink Job
programmatically.
When I do an executionEnv.execute() where executionEnv is an
StreamExecutionEnvironment, I get back a JobExecutionResult. I find no way
to stop the job (say based on some timeout) from a JobExecutio