Flink CDC里如果我doris分区字段也设置create_time,怎么做有这个效果？

在 Flink CDC 中，如果 Doris 分区字段设置了 create_time，并且你期望的格式是 yyyy-MM-dd，通常需要对从 MySQL 中读取的 create_time 进行转换。

Flink CDC 提供了数据类型的转换功能，可以将源端的数据类型转换为目标端所需的数据类型。对于日期和时间类型，可以使用 Flink 中的日期和时间函数进行格式化和转换。

以下是一个示例代码片段，演示如何使用 Flink SQL 将 MySQL 中的 create_time 转换为 yyyy-MM-dd 格式：

SELECT
    -- 其他字段...
    DATE_FORMAT(create_time, 'yyyy-MM-dd') AS formatted_create_time
FROM
    KafkaTable;

在上面的代码中，KafkaTable 是代表从 Kafka 中读取数据的表名。你可以根据实际情况将其替换为你所使用的表名。

通过使用 DATE_FORMAT 函数，并指定 'yyyy-MM-dd' 作为格式化字符串，可以将 create_time 字段转换为你期望的日期格式。

请注意，上述代码仅展示了如何在 Flink SQL 中进行日期格式转换的部分。你需要将其集成到你的数据处理流程中，确保正确地读取和写入数据。

一般不会动原字段的。此回答来自钉群Flink CDC 社区。