在使用K8S运行flink中,公司提供通用镜像包, 通过userJar 加载用户的自己的任务jar 其中任务jar中,启动任务的时候自己实现了使用JavaCompiler动态编译class文件, 在YARN PRE模式没有问题,但是使用k8s的时候就会报错呢
其中需要动态编译的class文件的依赖在 用户Jar中都是存在的,但是启动却包找不到依赖的类; 转换类加载方式也是无效的 classloader.resolve-order: parent-first , 除非把class文件依赖的类包,放入flink lib下面才有效 但是依赖的东西太多 每次都去新增就失去动态编译的意义 是否存在其他的解决方法?
相似问题