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)
