Flink CDC Oracle 数据更新后同步， 会导致数据B_LOB，C_LOB丢失 各位？

在使用 Flink CDC 同步 Oracle 数据库时，如果出现数据丢失的情况，可能是由于一些常见问题导致的，例如：

CDC 作业配置问题：在使用 Flink CDC 时，需要正确配置 CDC 作业的参数和选项，包括数据源、输出方式、并发度等。如果配置不正确，可能会导致数据丢失或同步不完整。

Oracle 数据库配置问题：Oracle 数据库本身也有一些配置参数和限制，需要根据实际情况进行调整。例如，如果 Oracle 数据库中的 Lob 字段过大，可能会导致同步不完整或者数据丢失。

Flink CDC 版本问题：Flink CDC 的版本也会影响同步的性能和稳定性。如果您使用的是较旧的 Flink CDC 版本，可能会存在一些已知问题或者限制。因此，建议使用最新版本

在 Flink CDC 中同步 Oracle 数据库的更新时，可能会导致 BLOB（Binary Large Object）和 CLOB（Character Large Object）数据丢失的问题。这是因为 Flink CDC 默认情况下以 JSON 格式将变更数据写入到目标系统，而 BLOB 和 CLOB 数据类型无法直接以 JSON 形式表示。

解决此问题的一种方法是使用 CDC Connector 的 format 参数来配置合适的格式化选项，以支持 BLOB 和 CLOB 数据类型的正确序列化和反序列化。可以考虑以下两种选项：

1. 使用 Avro 格式：Avro 是一种二进制数据序列化格式，支持大型对象的处理。通过使用 Avro 格式，您可以确保 BLOB 和 CLOB 数据正确地进行序列化和反序列化，以防止数据丢失。

CREATE TABLE oracle_table (
  -- 定义表的字段
) WITH (
  'connector' = 'cdc',
  'format' = 'avro', -- 设置格式为 Avro
  -- 其他配置参数
);

2. 自定义序列化器：如果 Avro 格式不能满足您的需求，您还可以自定义序列化器来处理 BLOB 和 CLOB 数据类型。通过实现自定义的序列化器，您可以控制如何将 BLOB 和 CLOB 数据以适当的方式写入和读取。

// 示例代码中的 Java 代码片段
TableSchema schema = ...
schema = schema
    .toBuilder()
    .field("data", DataTypes.BYTES()) // 使用 BYTES 类型来表示 BLOB 或 CLOB
    .build();

// 自定义 CDC 转换器
CDCJsonTableSink sink = ...
sink.setDataType(schema);
sink.setEncoder(new CustomBlobClobEncoder());

在上述代码中，使用 BYTES 类型来代表 BLOB 或 CLOB 数据，并通过自定义的序列化器 CustomBlobClobEncoder 来处理这些数据类型。

请注意，具体的解决方案可能因您使用的 Flink 版本、Flink CDC 版本和 Oracle 数据库版本而有所不同。建议查阅 Flink CDC 的官方文档、社区支持或联系 Flink CDC 的开发者获取更详细的帮助和指导。