Hi Jan, this looks to me like a bug for which you could create a JIRA and PR to fix it. Just to make sure, I've pulled in Aljoscha who is the author of this change to check with him whether we are forgetting something.
Cheers, Till On Fri, Aug 30, 2019 at 3:44 PM Jan Lukavský <je...@seznam.cz> wrote: > Hi, > > I have come across an issue with classloading in Flink's MiniCluster. > The issue is that when I run local flink job from a thread, that has a > non-default context classloader (for whatever reason), this classloader > is not taken into account when classloading user defined functions. This > is due to [1]. Is this behavior intentional, or can I file a JIRA and > use Thread.currentThread.getContextClassLoader() there? I have validated > that it fixes issues I'm facing. > > Jan > > [1] > > https://github.com/apache/flink/blob/ce557839d762b5f1ec92aa1885fd3d2ae33d0d0b/flink-runtime/src/main/java/org/apache/flink/runtime/execution/librarycache/BlobLibraryCacheManager.java#L280 > >
