[FLINK-21238] Support to close PythonFunctionFactory

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.13.0
• Component/s: API / Python
• Labels: pull-request-available
• Assignee: Dian Fu
• Reporter: Dian Fu
• Created: 02/Feb/21 07:54
• Updated: 28/May/21 08:57
• Resolved: 07/Feb/21 06:51

Description

PythonFunctionFactory is used to convert a Python class to a Java PythonFunction representation which could then be used as a user-defined function. Underlying PythonFunctionFactory, there is a Python process which is used to perform the actual conversion work. Currently, the Python process is added to shutdown hook and closed when the JVM exits. The aim of this JIRA is to provide more flexibility for users by introducing a close method to PythonFunctionFactory. This will allow PythonFunctionFactory to be closed manually and periodically which is important when integrating this feature in the platforms. 

Issue Links

• links to: GitHub Pull Request #14842