Mailing-List: contact dev-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@flink.apache.org
Received-SPF: pass (athena.apache.org: domain of amitpawar5388@gmail.com
 designates 209.85.214.180 as permitted sender)
MIME-Version: 1.0
Date: Mon, 30 Mar 2015 17:22:01 +0200
Message-ID: 
 <CAOP_KEwDvTRphZ6cst15HbOQcF4ea2Ek7hLw=wxVtYV5H+JAkg@mail.gmail.com>
Subject: Extracting detailed Flink execution plan
From: Amit Pawar <amitpawar5388@gmail.com>
To: dev@flink.apache.org
Content-Type: multipart/alternative; boundary=e89a8f838e092e47fb0512830bda

--e89a8f838e092e47fb0512830bda
Content-Type: text/plain; charset=UTF-8

Hi

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

--e89a8f838e092e47fb0512830bda--