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

• Type: Bug
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.9.1
• Component/s: Table SQL / API
• Labels: auto-deprioritized-major auto-deprioritized-minor
• Assignee: Unassigned
• Reporter: cloudzhao
• Created: 26/Apr/20 08:38
• Updated: 15/Nov/21 22:38

Description

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