隔离表结构示例
隔离表结构示例
CREATE TABLE dw_quarantine.order_fail (
order_id BIGINT,
payload STRING, -- 原始行序列化内容
dq_rule STRING, -- 触发的规则标识
src_partition STRING, -- 来源分区
fail_time TIMESTAMP
) PARTITIONED BY (dt STRING);修复后重放走幂等写入（按主键 upsert），避免修复数据与增量数据重复叠加。