问题描述:
最近在进行大数据平台的开发,有一个使用场景是Flink从Kafka中topic A中消费数据,进行一定的处理之后作为生产者推送到Kafka的topic B中,再由Doris订阅Kafka topic B中的数据写入到数据库中。在运行上述Flink程序的时候,报错:

java: 读取/Users/panpanmn/.m2/repository/com/zaxxer/SparseBitSet/1.2/SparseBitSet-1.2.jar时出错; zip END header not found

在ChatGPT的建议下尝试清理maven仓库并重新构建项目:

mvn dependency:purge-local-repository
mvn clean install

但在执行第一个命令时就开始WARNING:

[WARNING] Could not validate integrity of download from https://maven.aliyun.com/repository/spring/com/zaxxer/SparseBitSet/1.2/SparseBitSet-1.2.pom
org.eclipse.aether.transfer.ChecksumFailureException: Checksum validation failed, expected <!doctype but is 5166b6f8ee81598b7929e49e341d404ad31a068f
    at org.eclipse.aether.connector.basic.ChecksumValidator.validateExternalChecksums (ChecksumValidator.java:174)

检查了一下项目的pom.xml,发现用的是阿里云镜像
在这里插入图片描述
这说明阿里云镜像仓库里的SparseitSet本身就是有问题的

尝试进入到/Users/panpanmn/.m2/repository/com/zaxxer/目录下,发现SparseitSet确实存在,全部删除之后重新下载编译还是会出现相同的问题。

于是从maven官网直接输入文件名称,下载对应的版本文件,将自己本地仓库的spring-core-5.2.8.RELEASE.jar文件更换即可解决

https://mvnrepository.com/artifact/com.zaxxer/SparseBitSet
在这里插入图片描述
在这里插入图片描述
下载好之后进行替换:
在这里插入图片描述
重新运行成功。

阿里云你害人不浅。。。

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐