[
https://issues.apache.org/jira/browse/FLINK-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaozilong updated FLINK-19687:
-------------------------------
Description:
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`?
was: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()`.
> 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
> Priority: Major
>
> 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`?
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
