[jira] [Created] (FLINK-17388) flink sql The custom function in ROW type is executed multiple times

[Shang Yuanchun (Jira)]

cloudzhao created FLINK-17388:
---------------------------------

             Summary: flink sql  The custom function in ROW type is executed multiple times
                 Key: FLINK-17388
                 URL: https://issues.apache.org/jira/browse/FLINK-17388
             Project: Flink
          Issue Type: Bug
            Reporter: cloudzhao


val tableA = tableEnv.sqlQuery("select custom_func(a) as a, custom_func(b) as b from tableS")

tableEnv.registerTable("tableA", tableA)

val tableB = tableEnv.sqlQuery("select ROW(a, b) as body from tableA")

tableEnv.registerTable("tableB", tableB)

val tableC = tableEnv.sqlQuery("select body.a, body.b from tableB")

In this logic, the custom_func is executed four times

tableC === select Row(custom_func(a) as a, custom_func(b) as b).a, Row(custom_func(a) as a, custom_func(b) as b).b from tableS



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