记一次Doris增加字段后重建例行导入保证数据不重复

步骤记录

1. 增加字段 platform: ALTER TABLE TABLENAME ADD COLUMN COLUMNNAME VARCHAR(100) comment “xxx;

2. 停止例行导入 STOP ROUTINE LOAD FOR XX_JOB

3.记录kafka中的offset 1011

4.新建例行导入 修改offsets值

FROM KAFKA
(
"kafka_partitions"="0",
"kafka_offsets" = "1011"
);

5.启动例行导入

RESUME ROUTINE LOAD FOR XX_JOB