Flink CDC中Binlog日志没有存那么久，那怎么全量同步呢？

全量同步是基于查询的，类似datax
具体看flink-connector-mysql-cdc源码.

查记录总数及任务分割
com.ververica.cdc.connectors.mysql.source.assigners.ChunkSplitter
private List splitTableIntoChunks() {
final Object[] minMaxOfSplitColumn = queryMinMax(jdbc, tableId, splitColumnName);
}

查询数据

com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask
private void createDataEventsForTable () {

ResultSet rs = selectStatement.executeQuery()

}

全量同步好像是使用的快照，不是binlog 日志， 官网有说明，你看下，flink 会自动从全量切换到增量。增量快照不是datax的模式（无锁），具体实现去看原理，群文件都有或者github的wiki里面有书本。此答案整理至钉群“Flink CDC 社区“。