数据湖探索 DLI-Postgres CDC源表:注意事项

时间:2024-11-16 13:21:41

注意事项

  • 创建Flink OpenSource SQL作业时,在作业编辑界面的“运行参数”处,“Flink版本”需要选择“1.12”,勾选“保存作业日志”并设置保存作业日志的OBS桶,方便后续查看作业日志。
  • PostgreSQL的版本不能低于PostgreSQL 11。
  • 若Postgres表有update等操作,需要在PostgreSQL中执行下列语句。注意:test.cdc_order需要修改为实际的数据库和表。
    ALTER TABLE test.cdc_order REPLICA IDENTITY FULL
  • 使用前请确认当前PostgreSQL是否包含默认的插件,可在PostgreSQL中使用下述语句查询当前插件。
    SELECT name FROM pg_available_extensions;

    若不包含默认插件名“decoderbufs”,则需要在创建PostgreSQL CDC源表中配置参数“decoding.plugin.name”,该参数指定PostgreSQL中已有的插件。

support.huaweicloud.com/sqlref-flink-dli/dli_08_0388.html