[jira] [Created] (FLINK-14181) TableEnvironment explain maybe causes StreamGraph to be inconsistent

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

[jira] [Created] (FLINK-14181) TableEnvironment explain maybe causes StreamGraph to be inconsistent

Shang Yuanchun (Jira)
jianlong miao created FLINK-14181:
-------------------------------------

             Summary: 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


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



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