Hi 你的图挂了,如果单纯想解决 jar 包冲突的问题,那么 maven shade plugin[1] 或许对你有用
[1] https://maven.apache.org/plugins/maven-shade-plugin/examples/class-relocation.html Best, Congxian LakeShen <[email protected]> 于2020年7月16日周四 下午6:03写道: > Hi 社区, > > 我现在正在迁移任务到 k8s ,目前版本为 Flink 1.6 版本,k8s 上面作业运行模式为 standalone per job. > > 现在遇到一个问题,业务方 Flink jar 任务使用了 org.apache.calcite.avatica 依赖,也就是下面依赖: > <dependency> > <groupId>org.apache.calcite.avatica</groupId> > <artifactId>avatica-core</artifactId> > <version>${avatica.version}</version> > </dependency> > > 但是这个依赖其实在 flink-table 模块中,也有这个依赖: > [image: image.png] > > 由于 flink on k8s standalone per job 模式,会把 Flink 任务 jar 包放入到 flink 本身的lib > 包中,我在任务启动的时候,就会报: > Caused by: java.lang.NoClassDefFoundError: Could not initialize class > org.apache.calcite.avatica.ConnectionPropertiesImpl 错误。 > > 按照我的理解,由于 Flink jar 任务包中有 avatica-core 依赖,同时在 flink lib > 目录下面,flink-table_2.11-1.6-RELEASE.jar 中也有这个依赖,这两个都在 lib 目录下,然后就出现了类冲突问题。 > > 请问怎么解决这个问题呢,非常期待你的回复。 > > Best, > LakeShen > > >
