[FLINK-16533] ExecutionEnvironment supports execution of existing plan

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Won't Fix
• Component/s: Client / Job Submission
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: godfrey he
• Created: 11/Mar/20 04:53
• Updated: 09/Apr/20 10:18
• Resolved: 09/Apr/20 10:01

Description

Currently, ExecutionEnvironment only supports executing the plan generated by self.
FLIP-84 proposes TableEnvironment can only trigger the table program and the StreamExecutionEnvironment/ExecutionEnvironment can only trigger DataStream/DataSet program. This requires that ExecutionEnvironment can execute the plan generated by TableEnvironment. We propose to add two methods in ExecutionEnvironment: (which are similar to StreamExecutionEnvironment#execute(StreamGraph) and StreamExecutionEnvironment#executeAsync(StreamGraph))

public class ExecutionEnvironment {
    @Internal
    public JobExecutionResult execute(Plan plan) throws Exception {
    .....
    }

    @Internal
    public JobClient executeAsync(Plan plan) throws Exception {
    .....
    }
}

Issue Links

• is related to: FLINK-17052 Introduce PlanGenerator
• links to: GitHub Pull Request #11373