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

Flink CDC sqlserver 对flink版本有特殊要求吗?

Flink CDC中sqlsever cdc时 报Could not initialize class io.debezium.connector.sqlserver.SqlServerConnectorConfig 但是 mongo cdc就正常 代码都差不多 sqlserver 对flink版本有特殊要求吗?

展开
收起
cuicuicuic 2023-12-05 20:21:04 84 0
2 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    这个问题可能是由于Flink CDC SqlServer cdc连接器的版本与您的Flink版本不兼容导致的。首先,您需要确认一下您的Flink版本和flink-connector-sqlserver-cdc的版本是否相互兼容。然后,请确保已在 SQL Server 中启用了CDC功能,并创建了一个CDC实例。之后,在 Flink 中使用 CDC Connector 连接到 SQL Server,并使用 SQL Server中的。

    另外,这个问题也可能是由于缺少必要的依赖项或类路径问题引起的。例如,报错信息中提到的"Could not initialize class io.debezium.connector.sqlserver.SqlServerConnectorConfig",可能是因为Debezium的相关库没有被正确地添加到项目的依赖中。因此,您需要检查项目依赖是否正确配置,包括flink-sql-connector-sqlserver-cdc和Debezium的相关库。

    2023-12-05 21:06:41
    赞同 展开评论 打赏
  • 有的,每个版本依赖不同,需要兼容Flink CDC,并且jdbc版本也要求兼容一致

    2023-12-05 20:50:00
    赞同 展开评论 打赏

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

相关产品

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

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