sequence_col为非法属性

Viewed 18

doris建routine load时,加了一个sequencel_col的property属性,但是显示这个是一个非法属性--sequence_col is valid property

以下是执行的routine load创建语句
CREATE ROUTINE LOAD test_db3.raw_data_kafka_2_doris_1 ON raw_test_0401 COLUMNS(data_time, collect_time, sequence_col = -UNIX_TIMESTAMP(collect_time))
PROPERTIES
(
"desired_concurrent_number"="1",
"max_batch_interval" = "20",
"max_batch_rows" = "300000",
"max_batch_size" = "209715200",
"strict_mode" = "false",
"max_error_number" = "10000",
"format" = "json",
"sequence_col" = "sequence_col",
"jsonpaths" = "["$.dataTime","$.collectTime"]"
)
FROM KAFKA
(
"kafka_broker_list" = "xxx:9092",
"kafka_topic" = "test_for_sequence_in_doris",
"property.group.id" = "k2r1"
);

是想通过routine load把collect_time的相反数当作衍生列,然后根据主键使用collect_time较小的更新数据

1 Answers

ROUTINE LOAD 不支持在PROPERTIES使用sequencel_col,这是一个table的属性,你可以在建表的时候使用 seq_time作为sequencel_col,然后在routine load中使用seq_time= -UNIX_TIMESTAMP(collect_time))来满足你的需求