从您提供的错误信息来看,问题出在Flink CDC的依赖上。您可以尝试以下方法解决这个问题:
检查您的Flink版本是否与Flink CDC兼容。如果不兼容,请升级或降级Flink版本。
检查您的项目中是否有多个版本的Flink CDC依赖。如果有,请删除多余的依赖。
尝试使用Maven或Gradle将Flink CDC的依赖打包成一个fat jar文件。这样可以避免手动管理多个依赖。以下是使用Maven和Gradle的方法:
Maven:
<dependencyManagement> <dependencies> <dependency> <groupId>io.debezium</groupId> <artifactId>flink-cdc-connector-mysql</artifactId> <version>1.7.0.Final</version> </dependency> </dependencies> </dependencyManagement>
Gradle:
implementation 'io.debezium:flink-cdc-connector-mysql:1.7.0.Final'
将生成的fat jar文件放到Flink安装目录的lib下。
希望以上方法能帮助您解决问题。