Flink 1.13.3 和 FlinkCDC 2.4.1 之间的 guava 冲突是由于它们使用了不同版本的 Guava 库。具体来说,Flink 1.13.3 使用的是 flink-shaded-guava 18.0-13.0 版本,而 FlinkCDC 2.4.1 使用的是 flink-shaded-guava 30.1.1-jre 版本。
为了解决这个问题,您可以采取以下步骤:
- 使用 Maven 或 Gradle 等构建工具,在 Flink CDC 2.4 的 pom.xml 或 build.gradle 文件中将 Guava 30 依赖替换为 Guava 18。
- 运行构建命令编译 Flink CDC 2.4:mvn clean package 或 gradle clean build。
- 在编译成功后,使用打包生成的 JAR 文件来替换原始的 Flink CDC JAR 文件。
请注意,替换 Guava 版本后可能需要进行一些测试和调整,以确保 Flink CDC 2.4 的正常运行和稳定性。还应当注意 Guava 18 版本与其他依赖库的兼容性,以避免出现其他兼容性问题。