[jira] [Created] (FLINK-19687) Support to get execution plan in `StatementSet`

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-19687) Support to get execution plan in `StatementSet`

Shang Yuanchun (Jira)
xiaozilong created FLINK-19687:
----------------------------------

             Summary: Support to get execution plan in `StatementSet`
                 Key: FLINK-19687
                 URL: https://issues.apache.org/jira/browse/FLINK-19687
             Project: Flink
          Issue Type: Wish
          Components: Table SQL / API
    Affects Versions: 1.11.0
            Reporter: xiaozilong


Hi, I want to get job's execution plan in Flink SQL 1.11, but i meet exception "No operators defined in streaming topology. Cannot execute." when use `env.getExecutionPlan()`. The same code runs fine in Flink SQL 1.10. I found translation operations only happen when StatementSet.execute() is called in Flink SQL 1.11. So we cannot get job's execution plan before the job submit? Can we support to get execution plan in `StatementSet` or invoke method `TableEnvironmentImpl#translate` in `StatementSetImpl#addInsertSql`? I think the latter is better so that we can reuse `env.getExecutionPlan()`.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)