Hi Nikolaos,
As Ron said, the jobgraph is a low level structure in flink and it is not
exposed to users now. Currently you can get job details from
`RestClusterClient` in method `getJobDetails(JobID jobId)`, the result
`JobDetailsInfo` contains all vertices in the job and the json format job
plan.
This may or may not help, but you can get the execution plan from
inside the client, by doing something like this (I printed the plan to
stderr):
...
System.err.println(env.getExecutionPlan());
env.execute("my job");
The result is a JSON-encoded representation of the job graph, which
Hi, Nikolaos
As far as I know, JobGraph is a relatively low-level concept, and currently
we don't expose it directly to users, and don't provide a direct Restful
API to get it from JobManager. Why do you need to get JobGraph and what is
your real need?
Best,
Ron
Nikolaos Paraskakis 于2023年8月31日周
