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)