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

Flink CDC设置了没有生效,是还需要再表设置什么属性吗?

Flink CDC中includeSchemaChanges = true 设置了没有生效,是还需要再表设置什么属性吗?image.png
Caused by: org.postgresql.util.PSQLException: ERROR: could not access file "decoderbufs": No such file or directory
是不是需要安装支持这种 decoderbufs 解码的?

展开
收起
真的很搞笑 2023-09-28 10:51:39 117 0
1 条回答
写回答
取消 提交回答
  • 设置 Flink CDC 需要在表上设置以下属性:

    cdc.enabled:是否开启 CDC 功能。
    cdc.is_managed:CDC 数据是否由 Flink 管理。
    cdc.timestamp_column:CDC 数据的时间戳列。
    cdc.column_names:CDC 数据的列名。
    如果您没有在表上设置这些属性,则 CDC 不会生效。

    以下是一个示例:

    CREATE TABLE orders (
    order_id BIGINT NOT NULL,
    customer_id BIGINT NOT NULL,
    order_date DATE NOT NULL,
    order_amount DECIMAL(10,2) NOT NULL,
    PRIMARY KEY (order_id)
    ) WITH (
    cdc.enabled = true,
    cdc.is_managed = true,
    cdc.timestamp_column = order_date,
    cdc.column_names = (order_id, customer_id, order_date, order_amount)
    );
    希望这个回答对您有所帮助。

    2023-10-17 10:12:51
    赞同 展开评论 打赏

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

相关产品

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

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