[FLINK-11045] UserCodeClassLoader has not been set correctly for RuntimeUDFContext in CollectionExecutor

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.6.3, 1.7.1, 1.8.0
• Component/s: Table API & SQL
• Labels: pull-request-available
• Assignee: Hequn Cheng
• Reporter: Hequn Cheng
• Created: 02/Dec/18 06:24
• Updated: 05/Dec/18 09:50
• Resolved: 05/Dec/18 09:50

Description

We should use UserCodeClassLoader when new a RuntimeUDFContext.

i.e., Change the code from

this.classLoader = getClass().getClassLoader();

new RuntimeUDFContext(taskInfo, classLoader, executionConfig, cachedFiles, accumulators, metrics)

to

new RuntimeUDFContext(taskInfo, Thread.currentThread().getContextClassLoader, executionConfig, cachedFiles, accumulators, metrics)

in CollectionExecutor.

FYI. This is a problem reported from the user mailing list.

Issue Links

• is related to: FLINK-7490 UDF Agg throws Exception when flink-table is loaded with AppClassLoader
• links to: GitHub Pull Request #7213