问题描述

在使用Flink CDC 3.0将MySQL整库同步到Doris时，发现MySQL中新增的表无法同步到Doris。

可能的原因及解决方案

1、原因一：Flink CDC任务配置问题

解决方案：检查Flink CDC任务的配置，确保已经开启了整库同步功能，具体配置如下：

DataStream<Row> mysqlCDC = env.addSource(JdbcConnectionOptions.builder()
        .withUrl("jdbc:mysql://localhost:3306/")
        .withDriverName("com.mysql.jdbc.Driver")
        .withUsername("root")
        .withPassword("password")
        .build())
        .returns(Types.ROW_NAME(types))
        .startFromLatest()
        .failOnError()
        .withMaxRetries(5)
        .withRetryInterval(Duration.ofSeconds(10))
        .withMaxRetriesExceededOnTimeout(true)
        .withCheckpointMode(CheckpointMode.EXACTLY_ONCE);

2、原因二：MySQL表结构变更未触发同步

解决方案：检查MySQL表结构是否发生了变化，如字段类型、字段名等，如果发生了变更，需要重新创建Flink CDC任务，以便同步新的表结构。

3、原因三：Doris表结构与MySQL表结构不一致

解决方案：检查Doris中的表结构是否与MySQL中的表结构一致，如果不一致，需要修改Doris中的表结构，使其与MySQL中的表结构保持一致。

4、原因四：网络或连接问题

解决方案：检查Flink CDC任务与MySQL之间的网络连接是否正常，如果存在网络问题，需要解决网络问题后重新创建Flink CDC任务。

归纳

在排查问题时，可以从以上四个方面进行逐一排查，找到问题的根本原因，并采取相应的解决方案。