我使用的是flink-1.12.0版本,启动的单机集群;在我的flink程序main方法中,我使用URLClassLoader加载了一个http://a.jar的jar包,通过该类加载器加载我的自定义代码类,然后通过rest api 调用jar/run接口执行我提前上传好的uber-jar, 当我多次启动job时,我的自定义代码类没有重新加载,请问这种情况如何处理?而我uber-jar中的类有更新则发现类是重新加载的,请问这是如何实现的?谢谢! *来自志愿者整理的flink邮件归档
standalone 集群 session 模式,作业的 main 方法应该是在 client 端执行的。*来自志愿者整理的flink邮件归档
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。