flink cdc 实时同步 oracle hudi

要实现Flink CDC实时同步Oracle到Hudi，你可以按照以下步骤进行操作：

1. 首先，配置Flink的Savepoints和Checkpoints，这样就可以实现断点续传的功能。这在生产环境中是建议的配置。

2. 使用Flink SQL创建Hudi表并进行元数据自动同步到Hive。你可以按照以下示例创建表：

CREATE TABLE source_table (
   uuid varchar(20),
   name varchar(10),
   age int,
   ts timestamp(3),
   `partition` varchar(20)
) WITH (
   'connector' = 'datagen',
   'rows-per-second' = '1'
);

CREATE TABLE hudi_table (
   uuid varchar(20),
   name varchar(10),
   age int,
   ts timestamp(3),
   `partition` varchar(20)
) WITH (
   'connector' = 'hudi',
   'path' = '$HUDI_DEMO/t2', -- 将$HUDI_DEMO替换为实际的绝对路径
   'table.type' = 'MERGE_ON_READ',
   'write.bucket_assign.tasks' = '2',
   'write.tasks' = '2',
   'hive_sync.enable' = 'true',
   'hive_sync.mode' = 'hms',
   'hive_sync.metastore.uris' = 'thrift://ip:9083' -- 将ip替换为HMS的地址
);

INSERT INTO hudi_table SELECT * FROM source_table;

以上示例创建了`source_table`作为源表和`hudi_table`作为Hudi表，然后将源表的数据实时同步到Hudi表中。请将`$HUDI_DEMO`替换为实际的绝对路径，将`ip`替换为HMS的地址。

3. 确保你已经下载了所需的依赖jar。你需要下载MySQL驱动器以及Flink SQL的连接器和Flink CDC的依赖。你可以根据以下链接自行下载所需的jar包：

- Flink SQL连接器：https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/connectors/table/jdbc/
- Flink CDC依赖：https://ververica.github.io/flink-cdc-connectors/release-2.3/content/connectors/mysql-cdc(ZH).html#a-name-id-002-a

通过以上步骤，你可以实现Flink CDC实时同步Oracle到Hudi的功能。这将使数据同步变得简单且可靠。记得替换示例中的路径和地址为实际的值。