TiDB_PingCAP 的博客

TiDB_PingCAP 的博客 -

TiCDC 源码阅读(四)TiCDC Scheduler 工作原理解析

将一个 Changefeed 所有需要被同步的表,分发到不同的 TiCDC 节点上进行同步工作,以达到负载均衡的目的。维护每张表的同步进度,同时推进 Changefeed 的全局同步进度。本次介绍的 Scheduler 相关代码都在Coordinator 运行在 Changefeed,是 Scheduler 的全局调度中心,负责发送表调度任务,维护全部同步状态。Agent 运行在 Processor,它接收表调度任务,汇报当前节点上的表同步状态给 Coordinator。

TiCDC的Scheduler模块由Coordinator和Agent两部分组成,它们使用两阶段调度机制实现表调度任务,以减少挪动表过程耗时,降低对同步延迟的影响。Coordinator维护Capture的状态,ReplicationSet跟踪一张表在多个Capture上的表同步单元的状态,并且根据收到的Checkpoint和ResolvedTs保证二者均不会退。通过上述内容,读者可以对TiCDC的Scheduler模块有一个基本的了解。

scheduler ticdc 源码

相关推荐 去reddit讨论

热榜 Top10

Dify.AI
Dify.AI
LigaAI
LigaAI
观测云
观测云
eolink
eolink

推荐或自荐