Flink CDC mysql连接器配置这个选项,为啥不同步历史数据呢?

StartupOptions.initial() 是 Flink SQL Client 中用于初始化执行环境的选项。它包含了所有默认的 startup options，但并不包含任何特定的 startup option。

如果你想要同步历史数据，你需要在 Flink SQL 中显式地指定 START AT CURRENT_TIMESTAMP 或者 START AT UNIX_TIMESTAMP(...)。例如：

INSERT INTO MyTable
SELECT * FROM source
START AT CURRENT_TIMESTAMP;

或者

INSERT INTO MyTable
SELECT * FROM source
START AT UNIX_TIMESTAMP(my_timestamp_column);

这样，Flink CDC 任务就会从当前时间或者指定的 Unix 时间戳开始消费数据，从而同步历史数据。