问题描述
在 spark 项目中使用 kafka 和 delta_core 依赖项时,我收到下一个警告:
[WARNING] delta-core_2.12-0.7.0.jar,spark-sql-kafka-0-10_2.12-3.1.1.jar define 1 overlapping resources:
[WARNING] - META-INF/services/org.apache.spark.sql.sources.DataSourceRegister
这导致找不到增量源。如何同时包含 delta 和 kafka?谢谢。
这是我的 Maven 配置:
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-sql-kafka-0-10_${scala.version}</artifactId>
<version>${spark.version}</version>
</dependency>
<dependency>
<groupId>io.delta</groupId>
<artifactId>delta-core_${scala.version}</artifactId>
<version>0.7.0</version>
</dependency>
...
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-shade-plugin</artifactId>
<version>3.2.2</version>
<executions>
<execution>
<phase>package</phase>
<goals>
<goal>shade</goal>
</goals>
<configuration>
<transformers>
<transformer
implementation="org.apache.maven.plugins.shade.resource.AppendingTransformer">
<resource>
META-INF/services/org.apache.spark.sql.sources.DataSourceRegister
</resource>
</transformer>
</transformers>
<finalName>${project.artifactId}-${project.version}</finalName>
<artifactSet>
<includes>
<include>org.scalactic:*</include>
<include>io.delta:*</include>
<include>org.apache.spark:*</include>
</includes>
</artifactSet>
<filters>
<filter>
<artifact>*:*</artifact>
</filter>
</filters>
</configuration>
</execution>
</executions>
</plugin>
```
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)