Flink CDC里我mysql 数据库有个表它的字段定义为date类型，数值变化什么原因？

在Flink CDC中，当你遇到MySQL的DATE类型字段在读取binlog后被转换为数字形式时，这是因为Debezium MySQL Connector在处理DATE类型的字段时，默认情况下会将其转换为自1970-01-01以来的天数（即Unix时间戳格式，但不包括小时、分钟、秒部分）。

MySQL的DATE类型只包含年、月、日信息，而不含时分秒。因此，当你看到如19754这样的数字，实际上是表示从1970年1月1日开始算起的第19754天，转换回去就是2024年2月1日。

要解决这个问题，确保Debezium正确解析并格式化DATE字段到你期望的格式，可以在Debezium MySQL Connector的配置中指定如何处理日期类型。例如，可以通过如下配置让Debezium保持原始日期格式：

transforms: format
transforms.format.type: io.debezium.transforms.ByLogicalType
transforms.format.datetime.formats: "yyyy-MM-dd"

# 或者针对特定列进行转换
transforms: format_date
transforms.format_date.type: io.debezium.transforms.ExtractNewRecordState
transforms.format_date.field.whitelist: your_date_field_name
transforms.format_date.datetime.formats: "yyyy-MM-dd"

改成datetime。pekko.ask.timeout 参数调大一些。此回答来自钉群Flink CDC 社区。