开发者社区> 问答> 正文

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

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

展开
收起
JACKJACK 2021-12-08 15:50:15 1545 0
1 条回答
写回答
取消 提交回答
  • 对的是我!

    standalone 集群 session 模式,作业的 main 方法应该是在 client 端执行的。*来自志愿者整理的flink邮件归档

    2021-12-08 16:48:43
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Data as a Service - 数据即服务 -- MongoDB⾼级应⽤模式 立即下载
《基于 Service Worker 实现在线代理》 立即下载
开源广进-用Service Catalog构造K8S服务能力 立即下载