Re:Re: Re: K8s Appliaction模式无法支持flinkjar中Java动态编译?

2023-08-30 文章 周坤
是的我的任务的jar包里包含动态编译所有依赖的, 任务的jar是通过 k8s Apllication模式 userJar 方式进行动态加载的; 在 2023-08-30 12:14:18,"孙路昊" 写道: >依赖的jar包,有编译到启动jar包里面吗 > >周坤 <18679131...@163.com>于2023年8月30日 周三11:15写道: > >> >> 你好!在K8s模式中,动态编译缺失运行在UserJar中,启动的时候通过RIch算子的Open方法从第三方拉取原始class文件,然后进行动态编译进行缓存内存中, >> 按照YARN

Re: Re: K8s Appliaction模式无法支持flinkjar中Java动态编译?

2023-08-29 文章 孙路昊
依赖的jar包,有编译到启动jar包里面吗 周坤 <18679131...@163.com>于2023年8月30日 周三11:15写道: > > 你好!在K8s模式中,动态编译缺失运行在UserJar中,启动的时候通过RIch算子的Open方法从第三方拉取原始class文件,然后进行动态编译进行缓存内存中, > 按照YARN PER模式该方式是没有问题, 但是在K8s > Apllication模式,会找不到原始class文件中的依赖,其实在UserJar中有该文件的类依赖的; > 目前发现这个依赖类单独打jar包放在在lib目录下在框架运行时就加载才能找到依赖类,但是又不太符合规范;

Re: K8s Appliaction模式无法支持flinkjar中Java动态编译?

2023-08-23 文章 Weihua Hu
Hi, 抱歉我对 JavaCompiler 不是非常了解,我想知道这些动态编译是运行在 UserJar 的 main 方法中吗?以及编译的产物是怎么传递给 Flink 的? Best, Weihua On Tue, Aug 22, 2023 at 5:12 PM 周坤 <18679131...@163.com> wrote: > 你好! > > 有一个关于flink K8S apllication模式运行的问题需要解答下; > > 原本又yarn per模式运行的flink需要切换到K8s apllication模式; > > > > >