flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Amit Pawar <amitpawar5...@gmail.com>
Subject Extracting detailed Flink execution plan
Date Mon, 30 Mar 2015 15:22:01 GMT

I am trying to extract/retrieve the Flink execution plan. I managed to get
it as JSON string in following ways:
1. Using JAR - via PackagedProgram using getPreviewPlan() ; or
2. Directly in program - via ExecutionEnvironment's getExecutionPlan()

My question is - Is it possible to retrieve directly the Plan object?
I tried for this but was not successful as submitting the jar takes us into
interactive mode, and in order to use the other mode, programEntryPoint,
the main class needs to implement Program interface with getPlan method.

Even if we manage to get the execution plan as a Plan object, will it be
different from what we have using JSON string? like in terms of -
1. What are the datatypes used in the dataset's tuple
2. On what key is the Join taking place
3. Filtering predicate
4. Field for Distinct and so on
(JSON plan does have the operator tree but the contents field points to the
line of code in the class, which is not that helpful)

If not, is it possible (by some other way) to get the above details just by
using the Flink job/jar as an input?

Thanks and Regards
Amit Pawar

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message