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

Flink CDC导入最新的2.4.0 报出如上错误!我不想打jar包 想在flink sql实?

Flink CDC导入最新的2.4.0 报出如上错误image.png在sql 中可以看到 设置tableauimage.png 之前的2.3.0 schema-name支持啊 ?image.png 我不想打jar包 想在flink sql实现 ,把schema-name取消 出现这个错误

展开
收起
cuicuicuic 2023-07-01 19:06:45 70 0
3 条回答
写回答
取消 提交回答
  • 如果您想在Flink SQL中使用最新的Flink CDC 2.4.0,可以按照以下步骤进行配置:

    1. 下载Flink CDC 2.4.0的依赖包并解压。 2. 将解压后的依赖包中的flink-sql-connector-cdc-2.4.0.jar文件拷贝到Flink的lib目录中。 3. 在Flink SQL中使用Flink CDC,可以使用以下语句进行导入:

    CREATE TABLE my_table (
      id INT,
      name STRING,
      age INT
    ) WITH (
      'connector' = 'cdc',
      'database-name' = 'my_database',
      'table-name' = 'my_table',
      'scan.startup.mode' = 'earliest-offset',
      'debezium-json.schema-include' = 'true',
      'debezium-json.timestamp-format.standard' = 'ISO-8601'
    );
    

    其中,'database-name''table-name'分别指定要同步的数据库和表名,其他参数根据实际情况进行配置。

    需要注意的是,Flink CDC 2.4.0目前可能不支持所有的数据库和数据源。如果您使用的数据库或数据源不在支持列表中,可能需要自行编写Flink CDC的connector,或者等待Flink CDC的后续版本提供支持。建议查阅官方文档和相关资源,以获取更多详细信息和示例

    2023-07-30 13:57:05
    赞同 展开评论 打赏
  • 北京阿里云ACE会长

    如果您想在 Flink SQL 中使用 Flink CDC 2.4.0,可以按照以下步骤进行配置:
    下载 Flink CDC 2.4.0 的依赖包并解压。
    将解压后的依赖包中的 flink-sql-connector-cdc-2.4.0.jar 文件拷贝到 Flink 的 lib 目录中。
    在 Flink SQL 中使用 Flink CDC,可以使用以下语句进行导入:
    sql
    Copy
    CREATE TABLE my_table (
    id INT,
    name STRING,
    age INT
    ) WITH (
    'connector' = 'cdc',
    'database-name' = 'my_database',
    'table-name' = 'my_table',
    'scan.startup.mode' = 'earliest-offset',
    'debezium-json.schema-include' = 'true',
    'debezium-json.timestamp-format.standard' = 'ISO-8601'
    );
    其中,'database-name' 和 'table-name' 分别指定要同步的数据库和表名,其他参数根据实际情况进行配置。
    需要注意的是,Flink CDC 2.4.0 目前还不支持所有的数据库和数据源,如果您使用的数据库或数据源不在支持列表中,可能需要自行编写 Flink CDC 的 connector,或者等待 Flink CDC 的后续版本提供支持。

    2023-07-30 12:54:54
    赞同 展开评论 打赏
  • 看看官方文档呢,2.4的参数文档:https://github.com/ververica/flink-cdc-connectors/blob/release-2.4/docs/content/connectors/sqlserver-cdc.md,description是关键字吧,先把这一列去掉试试,https://github.com/ververica/flink-cdc-connectors/releases这里下载的,此回答整理自钉群“Flink CDC 社区”

    2023-07-01 19:24:08
    赞同 展开评论 打赏

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

相关产品

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

    更多
    SQL Server在电子商务中的应用与实践 立即下载
    GeoMesa on Spark SQL 立即下载
    原生SQL on Hadoop引擎- Apache HAWQ 2.x最新技术解密malili 立即下载