MAPREDUCE服务 MRS-配置同步任务的心跳和数据判齐:配置从Oracle(ogg)抓取数据到Hudi任务的心跳表

时间:2024-04-22 14:52:05

配置从Oracle(ogg)抓取数据到Hudi任务的心跳表

  1. 在需要同步数据的Oracle数据库中执行以下命令创建一张心跳表,心跳表归属于CDC_CDL Schema,表名为CDC_HEARTBEAT,主键为CDL_JOB_ID

    CREATE TABLE "CDC_CDL"."CDC_HEARTBEAT" (

    "CDL_JOB_ID" VARCHAR(22) PRIMARY KEY,

    "CDL_LAST_HEARTBEAT" TIMESTAMP,

    SUPPLEMENTAL LOG DATA (ALL) COLUMNS

    );

  2. CDC_HEARTBEAT表加入到Oracle或者ogg的任务中,确保心跳数据可以正常发送到Kafka。

    如果是Oracle任务,直接执行4

  3. 在CDL WebUI配置thirdparty-kafka(ogg)连接增加Oracle的连接信息。

  4. 配置完成后,在CDL WebUI界面创建从Oracle(ogg)抓取数据到Hudi任务并启动即可收到心跳数据。
support.huaweicloud.com/cmpntguide-lts-mrs/mrs_01_24811.html