在我的项目中,我希望在流执行之前访问Flink用户类加载器。在流执行之前,我一直在实例化自己的类加载器以反序列化类(尽力避免与多个类加载器相关的问题)。
然而,随着我进一步开发,我不得不编写更多的(糟糕的)代码来避免这个问题。
如果我可以访问Flink用户类加载器并使用它,这个问题就可以解决了,但是我没有看到除了 "RichFunctions" 之外的机制可以做到这一点(https://ci.apache.org/projects/flink/flink-docs-stable/api/java/org/apache/flink/api/common/functions/RichFunction.html),而这需要流正在运行。
任何指导都将不胜感激。
然而,随着我进一步开发,我不得不编写更多的(糟糕的)代码来避免这个问题。
如果我可以访问Flink用户类加载器并使用它,这个问题就可以解决了,但是我没有看到除了 "RichFunctions" 之外的机制可以做到这一点(https://ci.apache.org/projects/flink/flink-docs-stable/api/java/org/apache/flink/api/common/functions/RichFunction.html),而这需要流正在运行。
任何指导都将不胜感激。