开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

flink cdc使用报找不到这个jar包的方法,怎么回事?

flink cdc使用报找不到这个jar包的方法,怎么回事?服务器是有这个jar的,本地idea执行也没问题,打包provided去掉provided都试过。还是报一样的错误,有大佬知道怎么用这个cdc吗?667a3e58abdb7af362e6e0c06a1769b2.png

展开
收起
三分钟热度的鱼 2024-01-17 17:04:19 66 0
2 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    从提供的错误日志来看,问题出在Flink SQL连接器MySQL的依赖上。错误信息显示找不到MysqlsnapshotsplitAssimer类,这可能是由于缺少相应的jar包或者版本不匹配导致的。

    首先,请确保你的项目中包含了正确版本的Flink SQL连接器MySQL的jar包。你可以在项目的构建工具(如Maven或Gradle)中添加以下依赖:

    <dependency>
      <groupId>io.debezium</groupId>
      <artifactId>flink-connector-mysql</artifactId>
      <version>2.3.0</version>
    </dependency>
    

    如果你使用的是Maven,可以在pom.xml文件中添加上述依赖;如果是Gradle,可以在build.gradle文件中添加依赖。

    如果问题仍然存在,你可以尝试将缺失的jar包手动添加到项目的类路径中。通常,这些jar包位于Flink安装目录的lib文件夹下。你可以将这些jar包复制到项目的lib文件夹中,然后重新运行项目。

    2024-01-18 14:27:55
    赞同 展开评论 打赏
  • 这个看起来应该是jar冲突啦,你找一下这个class是不是在不同的jar中存在,应该至少有两个jar中的,包含了一个同路径的class。此回答整理自钉群“【②群】Apache Flink China社区”

    2024-01-17 18:01:32
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载