请教一个rountine load的问题,有个参数period_of_auto_resume_min ,(自动恢复 Routine Load 的周期)默认是5分钟。我理解是当有任务被暂停了,系统会自动尝试使用RESUME ROUTINE LOAD 把它调度回来。
目前的情况,我手动通过数据问题,触发暂停了一个job。一直没有自动恢复。是还需要开启什么其它的参数吗?
doris 版本2.1.6。
CREATE TABLE data_test.iot_rawdata(
id VARCHAR(255) NOT NULL COMMENT "id",
deviceId VARCHAR(255) COMMENT "设备id",
createTime VARCHAR(50) COMMENT "时间",
content String COMMENT "原始包体",
type VARCHAR(50) COMMENT "类型",
)
UNIQUE KEY(id)
DISTRIBUTED BY HASH(id) BUCKETS 5;
CREATE ROUTINE LOAD data_test.iot_rawdata_json ON iot_rawdata
-- with DELETE
COLUMNS(id,deviceId,createTime,content=FROM_UNIXTIME(createTime/1000 ),type)
-- ,WHERE deviceId>25
PROPERTIES(
"format"="json",
"jsonpaths"="["$.headers._uid","$.properties.温度","$.timestamp","$.messageType"]", -- ,"$.properties"
"max_error_number" = "2" -- , -- 2亿里只有能2个错误数据,第三个出现就会暂停任务
)
FROM KAFKA(
"kafka_broker_list" = "192.168.0.212:9092,192.168.0.213:9092",
"kafka_topic" = "flinkTestTopic",
"property.kafka_default_offsets" = "OFFSET_END"
);
手动是通过json的脏数据,没有_uid的json,触发表id不能为空策略暂停的。