对于Flink CDC，这个问题有同学遇到吗?

针对Flink CDC，有用户遇到了多种情况和问题，以下是一些常见问题及其解决方案的概览：

1. 如何在MySQL/Hologres CDC源表不支持窗口函数的情况下实现每分钟聚合统计？

   • 通过非窗口聚合方法实现。使用DATE_FORMAT函数将时间字段转换为分钟粒度字符串作为窗口值进行GROUP BY聚合。

2. MySQL CDC源表是否只能作为Source使用？

   • 是的，MySQL CDC主要用于读取MySQL数据库中的全量和增量数据，仅能作为数据流的源头（Source）。

3. 为什么MySQL CDC读取全量后不读取增量数据？

   • 可能是因为配置读取的是RDS MySQL 5.6备库或只读实例，建议使用可写实例或升级至更高版本MySQL。
   • 或因全量读取时间过长导致作业卡住，需增加并发数以加快速度。
   • 确保在进入增量读取前等待一个Checkpoint周期，确保数据完整性。

4. MySQL CDC中table-name正则表达式无法解析逗号怎么办？

   • 需要调整正则表达式避免使用Debezium不支持的逗号分隔符，例如使用(t_process_wi_history_\d{1}|t_process_wi_history_\d{2})格式。

5. 多个CDC作业导致数据库压力大怎么解决？

   • 考虑将表同步到Kafka消息队列中解耦，或者合并CTAS作业并复用Server ID减少压力。

6. 为何数据量不大但Flink读取时消耗大量带宽？

   • Binlog包含整个实例所有变更，即使只关注单表，也会读取全部Binlog。可通过Source复用优化带宽使用。

7. MySQL CDC增量阶段timestamp字段时区相差8小时的原因及解决？

   • 确保server-time-zone参数与MySQL服务器时区一致，或在自定义序列化器中正确处理时区信息。

8. Postgres服务器磁盘使用率高，WAL日志不释放原因？

   • 检查Postgres的checkpoint设置以及未使用的或延迟的slot状态。

9. Postgres CDC同步DECIMAL类型数据精度超限如何处理？

   • 配置'debezium.decimal.handling.mode' = 'string'，将超限的DECIMAL类型数据作为字符串处理。

10. DataStream API构建Postgres CDC Source时tableList选项如何配置？

    • 使用模式名加表名的形式，如my_schema.my_table。

以上是根据知识库资料整理的部分Flink CDC常见问题及其解决方案，希望能帮助您解决问题。如果您的问题未在此列出，请提供更具体的问题描述以便获得针对性的帮助。