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

Reply via email to