CREATE TABLE `tb_app_hudi_sync_state`
(
    `id`                        varchar(100) NOT NULL COMMENT '唯一标识',
    `message_id`                varchar(50)           DEFAULT NULL COMMENT 'pulsar 消息位移',
    `source_database`           varchar(50)           DEFAULT NULL COMMENT '源数据库',
    `source_schema`             varchar(50)           DEFAULT NULL COMMENT '源库',
    `source_table`              varchar(50)           DEFAULT NULL COMMENT '源表',
    `source_start_time`         datetime              DEFAULT NULL COMMENT '同步启动时间',
    `source_checkpoint_time`    datetime              DEFAULT NULL COMMENT '同步检查时间',
    `source_publish_time`       datetime              DEFAULT NULL COMMENT '消息发布时间',
    `source_op_time`            datetime              DEFAULT NULL COMMENT '消息业务时间',
    `source_application_id`     varchar(50)           DEFAULT NULL COMMENT '同步程序 application id',
    `source_cluster`            varchar(50)           DEFAULT NULL COMMENT '运行主机',
    `compaction_start_time`     datetime              DEFAULT NULL COMMENT '压缩启动时间',
    `compaction_finish_time`    datetime              DEFAULT NULL COMMENT '压缩完成时间',
    `compaction_message`        text COMMENT '压缩异常信息',
    `compaction_application_id` varchar(50)           DEFAULT NULL COMMENT '压缩任务 yarn id',
    `compaction_status`         varchar(20)           DEFAULT NULL COMMENT '压缩状态',
    `compaction_status_time`    datetime              DEFAULT NULL COMMENT '压缩事件时间',
    `compaction_cluster`        varchar(50)           DEFAULT NULL COMMENT '运行主机',
    `compaction_latest_op_ts`   datetime              DEFAULT NULL COMMENT '压缩提供的 latest_op_ts',
    `update_batch_marker`       varchar(100)          DEFAULT NULL COMMENT '更新批次号',
    `pulsar_back_log`           bigint(20)            DEFAULT NULL COMMENT 'pulsar 积压',
    `update_time`               datetime     NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
    `check_source_total`        bigint(20)            DEFAULT NULL,
    `check_source_total_time`   datetime              DEFAULT NULL,
    `check_target_total`        bigint(20)            DEFAULT NULL,
    `check_target_latest_op_ts` varchar(100)          DEFAULT NULL,
    `check_target_total_time`   datetime              DEFAULT NULL,
    PRIMARY KEY (`id`)
) DEFAULT CHARSET = utf8mb4 COMMENT ='表实时状态';