Flink CDC在获取全量数据阶段的时候是基于查询的，还是基于binlog日志的呢？

看源码，基于查询的

  <dependency>
      <groupId>com.ververica</groupId>
      <artifactId>flink-connector-mysql-cdc</artifactId>
      <version>2.2.0</version>
  </dependency>

查记录总数及任务分割
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()

}