[
https://issues.apache.org/jira/browse/FLINK-14181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jianlong miao updated FLINK-14181:
----------------------------------
Description:
Now TableEnviroment.explain will use StreamEnv to generateStreamGraph. That
will use execEnv::addOperator to add transformations.
If we have done to the current table after the explain some of the other,
making a sink, there will be a repeat of transformations, leading to repeated
job node in the job
was:
Now TableEnviroment.explain will use StreamEnv to generateStreamGraph. That
will use execEnv::addOperator to add transformations.
If we have done to the current table after the explain some of the other,
making sink again, there will be a repeat of transformations, leading to
repeated job node in the job
> TableEnvironment explain maybe causes StreamGraph to be inconsistent
> --------------------------------------------------------------------
>
> Key: FLINK-14181
> URL: https://issues.apache.org/jira/browse/FLINK-14181
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Reporter: jianlong miao
> Priority: Critical
>
> Now TableEnviroment.explain will use StreamEnv to generateStreamGraph. That
> will use execEnv::addOperator to add transformations.
> If we have done to the current table after the explain some of the other,
> making a sink, there will be a repeat of transformations, leading to repeated
> job node in the job
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
