数据仓库服务 GaussDB(DWS)-Flink实时消费Binlog:注意事项

时间:2025-02-12 15:01:49

注意事项

  • 当前仅8.3.0.100及以上的版本支持HStore和HStore-opt记录Binlog功能。
  • V3 HStore表不支持Binlog,仅V3 HStore_opt表支持Binlog,且V3处于试商用阶段,使用前需要进行评估。
  • 目前 GaussDB (DWS)只有Hstore表和HStore-opt支持Binlog功能,表需要包含主键且设置enable_binlog=on或者enable_binlog_timestamp=on。
  • 消费的Binlog表名不要带有特殊字符,如.、""等。
  • 如果多个任务消费同一张表的Binlog数据,需要保证每个任务的binlogSlotName唯一。
  • 为了达到最高的消费速度,建议将任务的并发度和DWS集群DN数设置一致。
  • 使用dws-connector-flink的Sink能力来写入Binlog数据的话,需要注意以下几点:
    • 如果需要保证DN内的数据写入顺序则需要设置connectionSize设置为1。
    • 如果源端有更新主键操作或者需要flink进行聚合计算的话,将ignoreUpdateBefore设置为false,否则不建议将 ignoreUpdateBefore设置为false(默认true)。
support.huaweicloud.com/HyDevg-910-dws/dws_15_00017.html