load脚本如下:
CREATE ROUTINE LOAD data_ngms.ods_ngms_tp_history_routine_load ON ods_ngms_tp_history COLUMNS (
stat_date,
dev_id,
device_id,
data_type,
warn_id,
warning,
`events`,
`data`,
`temp`,
`press`,
temp2,
press2,
`is_new`,
create_time,
update_time,
plan_id
) ,
where dev_id is not null
PROPERTIES ( "format" = "json", "jsonpaths" = "[\"$.data[0].stat_date\",\"$.data[0].dev_id\",\"$.data[0].device_id\",\"$.data[0].data_type\",\"$.data[0].warn_id\",\"$.data[0].warning\",\"$.data[0].events\",\"$.data[0].data\",\"$.data[0].temp\",\"$.data[0].press\",\"$.data[0].temp2\",\"$.data[0].press2\",\"$.data[0].is_new\",\"$.data[0].create_time\",\"$.data[0].update_time\",\"$.data[0].plan_id\"]" )
FROM
KAFKA ( "kafka_broker_list" = "192.168.3.177:9092,192.168.3.188:9092,192.168.3.199:9092,192.168.3.201:9092,192.168.3.211:9092", "kafka_topic" = "tidb_db_ngms_tp_history", "property.kafka_default_offsets" = "2024-12-18 00:00:00" );
where条件未生效，什么原因？
doris版本是2.1.7
