cdc 在flink SQL 的情况下，某个字段的旧数据 是1 变成了新数据 2 ？

是的，Flink SQL 可以获取到旧数据。在 Flink CDC 中，你可以使用 BEFORE 和 AFTER 关键字来定义源表和目标表之间的变化。当某个字段的值发生变化时，Flink CDC 会将变化的数据写入目标表中。

以下是一个示例：

CREATE TABLE source_table (
    id INT,
    field1 INT,
    field2 STRING
) WITH (
    'connector' = 'kafka',
    'topic' = 'source_topic',
    ...
);

CREATE TABLE target_table (
    id INT,
    field1 INT,
    field2 STRING
) WITH (
    'connector' = 'jdbc',
    'url' = 'jdbc:mysql://localhost:3306/mydb',
    'table-name' = 'target_table',
    ...
);

INSERT INTO target_table
SELECT id, field1, field2
FROM source_table
WHERE field1 = 1;

在这个示例中，我们首先创建了一个名为 source_table 的源表和一个名为 target_table 的目标表。然后，我们使用 INSERT INTO 语句将 source_table 中 field1 值为 1 的数据写入 target_table。这样，当 field1 的值从 1 变为 2 时，Flink CDC 会自动将变化的数据写入目标表中。