[jira] [Created] (FLINK-13088) Supports execute DAG plan

[Shang Yuanchun (Jira)]

godfrey he created FLINK-13088:
----------------------------------

             Summary: Supports execute DAG plan
                 Key: FLINK-13088
                 URL: https://issues.apache.org/jira/browse/FLINK-13088
             Project: Flink
          Issue Type: New Feature
          Components: Table SQL / Planner
            Reporter: godfrey he
            Assignee: godfrey he


in [FLINK-13081|https://issues.apache.org/jira/browse/FLINK-13081], {{explain}} method will be introduced to support explain multiple-sinks plan, this issue aims to introduce {{execute}} method into {{TableEnvironment}} to trigger the program execution. and in blink planner, queries will not be optimized immediately in {{insertInto}}/{{sqlUpdate}} methods, and will be optimized together in this method.

{code:java}
// Triggers the program execution
JobExecutionResult execute(String jobName) throws Exception;
{code}

there are two concerns about this method:
1. which {{execute}} methods ({{TableEnvironment#execute}} or {{StreamExecutionEnvironment#execute}}) users should use?
2.  how to make sure users only use {{TableEnvironment#execute}} method if their code only depends on planner module instead of bridge module？



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)