[FLINK-10451] TableFunctionCollector should handle the life cycle of ScalarFunction

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.5.5, 1.6.2, 1.7.0
• Component/s: Table SQL / API
• Labels: pull-request-available
• Assignee: Ruidong Li
• Reporter: Ruidong Li
• Created: 27/Sep/18 10:46
• Updated: 17/Oct/18 08:44
• Resolved: 02/Oct/18 10:33

Description

Considering the following query:

table.join(udtf('a)).where(udf('b))

the filter will be pushed into DataSetCorrelate/DataStreamCorrelate without triggering open() and close()

Issue Links

• links to: GitHub Pull Request #6771