如何用flinksql cdc同步数据时 新增两个字段标识出数据的创建时间和更新时间

若要使用 Flink SQL CDC 同步数据时新增两个字段标识出数据的创建时间和更新时间，可以采用如下步骤：

1. 在源表中添加创建时间和更新时间字段。例如：

CREATE TABLE source_table (
  id INT,
  name STRING,
  create_time TIMESTAMP,
  update_time TIMESTAMP
) WITH (
  'connector' = '...', 
  ...
);

2. 在目标表中添加创建时间和更新时间字段。例如：

CREATE TABLE target_table (
  id INT,
  name STRING,
  create_time TIMESTAMP,
  update_time TIMESTAMP
) WITH (
  'connector' = '...', 
  ...
);

3. 使用 Flink SQL CDC 将源表中的数据同步到目标表中。例如：

INSERT INTO target_table
SELECT id, name, create_time, update_time
FROM source_table;

其中，`create_time` 和 `update_time` 字段的值可以通过 Flink SQL 的内置函数 `CURRENT_TIMESTAMP()` 获取，例如：

INSERT INTO source_table
SELECT id, name, CURRENT_TIMESTAMP(), CURRENT_TIMESTAMP()
FROM ...

这样就可以在 Flink SQL CDC 同步数据时新增两个字段标识出数据的创建时间和更新时间了。