FlinkUserCodeClassLoader在session模式的集群下是如何卸载类的

[Asahi Lee]

你好！
       我使用的是flink-1.12.0版本,启动的单机集群；在我的flink程序main方法中，我使用URLClassLoader加载了一个http://a.jar的jar包，通过该类加载器加载我的自定义代码类，然后通过rest api 调用jar/run接口执行我提前上传好的uber-jar, 当我多次启动job时，我的自定义代码类没有重新加载，请问这种情况如何处理？而我uber-jar中的类有更新则发现类是重新加载的，请问这是如何实现的？谢谢！
      

[Xintong Song]

standalone 集群 session 模式，作业的 main 方法应该是在 client 端执行的。


Thank you~

Xintong Song



On Fri, Jan 22, 2021 at 9:52 AM Asahi Lee <[hidden email]> wrote:

> 你好！
> &nbsp; &nbsp; &nbsp;
> &nbsp;我使用的是flink-1.12.0版本,启动的单机集群；在我的flink程序main方法中，我使用URLClassLoader加载了一个
> http://a.jar的jar包 <http://a.xn--jarjar-gz4j285u>，通过该类加载器加载我的自定义代码类，然后通过rest
> api 调用jar/run接口执行我提前上传好的uber-jar,
> 当我多次启动job时，我的自定义代码类没有重新加载，请问这种情况如何处理？而我uber-jar中的类有更新则发现类是重新加载的，请问这是如何实现的？谢谢！
> &nbsp; &nbsp; &nbsp;&nbsp;