Re: Is there any way to get the ExecutionGraph of a Job

2019-06-03 Thread Debasish Ghosh
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

Re: Is there any way to get the ExecutionGraph of a Job

2019-06-03 Thread Yun Gao
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

Is there any way to get the ExecutionGraph of a Job

2019-06-03 Thread Debasish Ghosh
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