Hello everyone, I’d like to open a discussion on FLIP-260[1]: expose finish method for UserDefinedFunction, this makes a chance for users who rely on finish logic in the legacy close() method (< 1.14) to migrate to the new finish() method.
The task lifecycle was changed in FLINK-22972[2]: a new finish() phase was introduced (extracted the ‘finish’ part out of the ‘close’) and removed the dispose() method. This change was also done in table module (e.g., `AbstractMapBundleOperator` for mini-batch operation ) but not covered the UserDefinedFunction which only exposes open() and close() api for custom usage, those customers who rely on the legacy close() api may encounter wrong result or suffer runtime errors after upgrading to the new version. Strictly speaking, it is a bug caused by the breaking change, but due to the public api change, we propose this flip. Looking forward to your comments or feedback. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-260%3A+Expose+Finish+Method+For+UserDefinedFunction [2] https://issues.apache.org/jira/browse/FLINK-22972 Best, Lincoln Lee
