You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Teng Fei Liao (Jira)" <ji...@apache.org> on 2020/04/17 02:58:00 UTC

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

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)