[
https://issues.apache.org/jira/browse/FLINK-10451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-10451.
----------------------------------
Resolution: Fixed
Fix Version/s: 1.5.5
1.6.2
1.7.0
Fixed in 1.7.0: 22613b7392f6f9b344291bb3a5cec84c9aa40926
Fixed in 1.6.2: 7fb980ec74b95d7e6e27d6414af54deb9010e134
Fixed in 1.5.5: 9a1f0c5e05ef50f115c8f92aac9fc156cdf54249
> TableFunctionCollector should handle the life cycle of ScalarFunction
> ---------------------------------------------------------------------
>
> Key: FLINK-10451
> URL: https://issues.apache.org/jira/browse/FLINK-10451
> Project: Flink
> Issue Type: Bug
> Components: Table API & SQL
> Reporter: Ruidong Li
> Assignee: Ruidong Li
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.7.0, 1.6.2, 1.5.5
>
>
> Considering the following query:
> table.join(udtf('a)).where(udf('b))
> the filter will be pushed into DataSetCorrelate/DataStreamCorrelate without
> triggering open() and close()
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
