TiCDC 故障处理

    注意

    本文档 cdc cli 命令中指定 PD 地址为 --server=http://127.0.0.1:8300,在使用时需根据实际地址进行替换。

    • 通过 Grafana 检查同步任务的 changefeed checkpoint 监控项。注意选择正确的 changefeed id。如果该值不发生变化或者查看 checkpoint lag 是否不断增大,可能同步任务出现中断。
    • 通过 Grafana 检查 exit error count 监控项,该监控项大于 0 代表同步任务出现错误。
    • 通过 cdc cli changefeed listcdc cli changefeed query 命令查看同步任务的状态信息。任务状态为 stopped 代表同步中断,error 项会包含具体的错误信息。任务出错后可以在 TiCDC server 日志中搜索 error on running processor 查看错误堆栈,帮助进一步排查问题。
    • 部分极端异常情况下 TiCDC 出现服务重启,可以在 TiCDC server 日志中搜索 FATAL 级别的日志排查问题。

    可以使用 cdc cli 查询同步任务是否被人为终止。例如:

    上述命令的输出中 admin-job-type 标志这个同步的任务的状态:

    • 0: 任务进行中,没有被人为停止。
    • 1: 任务暂停,停止任务后所有同步 processor 会结束退出,同步任务的配置和同步状态都会保留,可以从 checkpoint-ts 恢复任务。
    • 2: 任务恢复,同步任务从 checkpoint-ts 继续同步。
    • 3: 任务已删除,接口请求后会结束所有同步 processor,并清理同步任务配置信息。同步状态保留,只提供查询,没有其他实际功能。

    目前已知可能发生的同步中断包括以下场景:

    • 下游持续异常,TiCDC 多次重试后仍然失败。

      • 处理方法:在下游恢复正常后,通过 HTTP 接口恢复同步任务。
    • 因下游存在不兼容的 SQL 语句,导致同步不能继续。

      • 该场景下 TiCDC 会保存任务信息,由于 TiCDC 已经在 PD 中设置的 service GC safepoint,在 gc-ttl 的有效期内,同步任务 checkpoint 之后的数据不会被 TiKV GC 清理掉。
      • 处理方法:
        1. 先通过 查询同步任务状态信息,记录 checkpoint-ts 值。
        2. 使用新的任务配置文件,增加ignore-txn-start-ts 参数跳过指定 start-ts 对应的事务。
        3. 通过 HTTP API 停止旧的同步任务,使用 cdc cli changefeed create,指定新的任务配置文件,指定 start-ts 为刚才记录的 checkpoint-ts,启动新的同步任务恢复同步。
    • 在 v4.0.13 及之前的版本中 TiCDC 同步分区表存在问题,导致同步停止。

      • 该场景下 TiCDC 会保存任务信息,由于 TiCDC 已经在 PD 中设置的 service GC safepoint,在 gc-ttl 的有效期内,同步任务 checkpoint 之后的数据不会被 TiKV GC 清理掉。
      • 处理方法:
        1. 通过 cdc cli changefeed pause -c <changefeed-id> 暂停同步。
        2. 等待约一分钟后,通过 cdc cli changefeed resume -c <changefeed-id> 恢复同步。

    如何处理 TiCDC 创建同步任务或同步到 MySQL 时遇到 Error 1298: Unknown or incorrect time zone: 'UTC' 错误?

    这是因为下游 MySQL 没有加载时区,可以通过 mysql_tzinfo_to_sql 命令加载时区,加载后就可以正常创建任务或同步任务。

    1. mysql_tzinfo_to_sql /usr/share/zoneinfo | mysql -u root mysql -p

    显示类似于下面的输出则表示导入已经成功:

    1. Enter password:
    2. Warning: Unable to load '/usr/share/zoneinfo/iso3166.tab' as time zone. Skipping it.
    3. Warning: Unable to load '/usr/share/zoneinfo/leap-seconds.list' as time zone. Skipping it.
    4. Warning: Unable to load '/usr/share/zoneinfo/zone.tab' as time zone. Skipping it.
    5. Warning: Unable to load '/usr/share/zoneinfo/zone1970.tab' as time zone. Skipping it.

    如果下游是特殊的 MySQL 环境(某种公有云 RDS 或某些 MySQL 衍生版本等),使用上述方式导入时区失败,就需要通过 sink-uri 中的 time-zone 参数指定下游的 MySQL 时区。可以首先在 MySQL 中查询其使用的时区:

    1. show variables like '%time_zone%';

    然后在创建同步任务和创建 TiCDC 服务时使用该时区:

    1. cdc cli changefeed create --sink-uri="mysql://root@127.0.0.1:3306/?time-zone=CST" --server=http://127.0.0.1:8300

    故障处理 - 图2

    注意

    CST 可能是以下四个不同时区的缩写:

    • 美国中部时间:Central Standard Time (USA) UT-6:00
    • 澳大利亚中部时间:Central Standard Time (Australia) UT+9:30
    • 古巴标准时间:Cuba Standard Time UT-4:00

    在中国,CST 通常表示中国标准时间,使用时请注意甄别。

    如何处理升级 TiCDC 后配置文件不兼容的问题?

    请参阅配置文件兼容注意事项

    当 changefeed 的下游为类 MySQL 数据库时,TiCDC 执行了一个耗时较长的 DDL 语句,阻塞了所有其他 changefeed,应该怎样处理?

    1. 首先暂停执行耗时较长的 DDL 的 changefeed。此时可以观察到,这个 changefeed 暂停后,其他的 changefeed 不再阻塞了。
    2. 在 TiCDC log 中搜寻 apply job 字段,确认耗时较长的 DDL 的 start-ts
    3. 手动在下游执行该 DDL 语句,执行完毕后进行下面的操作。
    4. 修改 changefeed 配置,将上述 start-ts 添加到 ignore-txn-start-ts 配置项中。
    5. 恢复被暂停的 changefeed。

    TiCDC 集群升级到 v4.0.8 之后,changefeed 报错 [CDC:ErrKafkaInvalidConfig]Canal requires old value to be enabled,为什么?

    自 v4.0.8 起,如果 changefeed 使用 canal-jsoncanal 或者 maxwell 协议输出,TiCDC 会自动开启 Old Value 功能。但是,当 TiCDC 是从较旧版本升级到 v4.0.8 或以上版本时,在 changefeed 使用 、canalmaxwell 协议的同时 TiCDC 的 Old Value 功能会被禁用。此时,会出现该报错。可以按照以下步骤解决该报错:

    1. 将 changefeed 配置文件中 enable-old-value 的值设为 true

    2. 使用 cdc cli changefeed pause 暂停同步任务。

      1. cdc cli changefeed pause -c test-cf --server=http://127.0.0.1:8300
    3. 使用 cdc cli changefeed update 更新原有 changefeed 的配置。

      1. cdc cli changefeed update -c test-cf --server=http://127.0.0.1:8300 --sink-uri="mysql://127.0.0.1:3306/?max-txn-row=20&worker-number=8" --config=changefeed.toml
    4. 使用 cdc cli changefeed resume 恢复同步任务。

    执行 pd-ctl service-gc-safepoint --pd <pd-addrs> 命令查询当前的 GC safepoint 与 service GC safepoint。如果 GC safepoint 小于 TiCDC changefeed 同步任务的开始时间戳 start-ts,可以直接在 cdc cli create changefeed 命令后加上 --disable-gc-check 参数创建 changefeed。

    如果 pd-ctl service-gc-safepoint --pd <pd-addrs> 的结果中没有 gc_worker service_id

    • 如果 PD 的版本 <= v4.0.8,详见 。
    • 如果 PD 是由 v4.0.8 或更低版本滚动升级到新版,详见 PD issue #3366
    • 对于其他情况,请将上述命令执行结果反馈到 。

    使用 TiCDC 同步消息到 Kafka 时 Kafka 报错 Message was too large,该如何处理?

    v4.0.8 或更低版本的 TiCDC,仅在 Sink URI 中为 Kafka 配置 max-message-bytes 参数不能有效控制输出到 Kafka 的消息大小,需要在 Kafka server 配置中加入如下配置以增加 Kafka 接收消息的字节数限制。

    1. # broker 能接收消息的最大字节数
    2. message.max.bytes=2147483648
    3. # broker 可复制的消息的最大字节数
    4. replica.fetch.max.bytes=2147483648
    5. # 消费者端的可读取的最大消息字节数
    6. fetch.message.max.bytes=2147483648

    TiCDC 同步时,在下游执行 DDL 语句失败会有什么表现,如何恢复?

    如果某条 DDL 语句执行失败,同步任务 (changefeed) 会自动停止,checkpoint-ts 断点时间戳为该条出错 DDL 语句的结束时间戳 (finish-ts) 减去一。如果希望让 TiCDC 在下游重试执行这条 DDL 语句,可以使用 cdc cli changefeed resume 恢复同步任务。例如:

    1. cdc cli changefeed resume -c test-cf --server=http://127.0.0.1:8300
    1. cdc cli changefeed create --server=http://127.0.0.1:8300 --sink-uri="mysql://root:123456@127.0.0.1:3306/" --changefeed-id="simple-replication-task" --sort-engine="unified" --start-ts 415241823337054210