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

Flink CDC中column default value的转换能关闭吗?

Flink CDC中column default value的转换能关闭吗?

展开
收起
真的很搞笑 2023-10-03 09:10:43 87 0
1 条回答
写回答
取消 提交回答
  • Flink CDC中column default value的转换是指当从数据库中读取变更数据时,如果某个字段的值为NULL,那么Flink CDC会尝试使用该字段在数据库中定义的默认值来替换NULL。这样做的目的是为了保持数据的一致性和完整性,避免出现空值导致的问题。

    如果想关闭这个功能,可以在创建Flink CDC表的时候,使用'column.default-value.enabled'参数来设置是否启用默认值转换。 该参数的默认值为true,表示启用默认值转换。如果想关闭默认值转换,可以将该参数设置为false。

    例如,如果想从MySQL读取变更数据,并且关闭默认值转换,您可以这样创建表:

    CREATE TABLE mysql_binlog (
      id INT NOT NULL,
      name STRING,
      description STRING,
      weight DECIMAL(10, 3)
    ) WITH (
      'connector' = 'mysql-cdc',
      'hostname' = 'localhost',
      'port' = '3306',
      'username' = 'flinkuser',
      'password' = 'flinkpw',
      'database-name' = 'inventory',
      'table-name' = 'products',
      'column.default-value.enabled' = 'false' -- 关闭默认值转换
    );
    
    2023-10-20 16:14:06
    赞同 1 展开评论 打赏

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

相关产品

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

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