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)