[jira] [Created] (FLINK-17195) Worker threads for source function have wrong ClassLoader

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-17195) Worker threads for source function have wrong ClassLoader

Shang Yuanchun (Jira)
Teng Fei Liao created FLINK-17195:
-------------------------------------

             Summary: Worker threads for source function have wrong ClassLoader
                 Key: FLINK-17195
                 URL: https://issues.apache.org/jira/browse/FLINK-17195
             Project: Flink
          Issue Type: Bug
          Components: Runtime / State Backends, Table SQL / Planner
    Affects Versions: 1.10.0
            Reporter: Teng Fei Liao


Hey, in one of my SourceFunctions, I'm calling ServiceLoader.load(MyDefiniedService.class) which internally fetches the ClassLoader by calling Thread.currentThread().getContextClassLoader(). It seems like whichever ClassLoader this fetches is unaware of any jars/code that I've shipped.

My application code has not changed and this came up in my attempt switch planners from the old planner to the blink planner. Would appreciate any help I can get on this, thanks.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)