Hequn Cheng created FLINK-11045:
-----------------------------------
Summary: UserCodeClassLoader has not been set correctly for
RuntimeUDFContext in CollectionExecutor
Key: FLINK-11045
URL: https://issues.apache.org/jira/browse/FLINK-11045
Project: Flink
Issue Type: Bug
Components: Table API & SQL
Reporter: Hequn Cheng
Assignee: Hequn Cheng
We should use {{UserCodeClassLoader}} when new a {{RuntimeUDFContext}}.
i.e., Change the code from
{code:java}
this.classLoader = getClass().getClassLoader();
new RuntimeUDFContext(taskInfo, classLoader, executionConfig, cachedFiles,
accumulators, metrics)
{code}
to
{code:java}
new RuntimeUDFContext(taskInfo, Thread.currentThread().getContextClassLoader,
executionConfig, cachedFiles, accumulators, metrics)
{code}
in {{CollectionExecutor}}.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
