Hey Alex, Flink has 3 abstractions having a Graph suffix in place currently for streaming jobs:
* StreamGraph: Used for representing the logical plan of a streaming job that is under construction in the API. This one is the only streaming specific in this list. * JobGraph: Used for representing the logical plan of a streaming job that is finished construction. * ExecutionGraph: The physical plan of the JobGraph, contains parallelism, estimated input sizes etc. env.getExecutionPlan gives you a JSON String representation of the ExecutionGraph, which should contain must of the info you need. To visualize that go to your flink binary distribution and open up tools/planVisualizer.html in a browser, paste the JSON there and hit the button. :) You might find it useful that the new Flink Dashboard also comes with this feature integrated, so you can visualize jobs that have been submitted to the cluster. Hope that helps, Marton On Thu, Jan 14, 2016 at 11:56 AM, lofifnc <alexander.k...@mni.thm.de> wrote: > Hi, > > I'm trying to figure out what graph the execution plan represents when you > call env.getExecutionPlan on the StreamExecutionEnvironment. From my > understanding the StreamGraph is what you call an APIGraph, which will be > used to create the JobGraph. > So is the ExecutionPlan is a full representation of the StreamGraph? > And Is there a way to get a human-interpretable representation of the > JobGraph? :) > > Best, > Alex > > > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Execution-Plan-tp4290.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
