我采用的是拉取kafka
use log_db;
CREATE ROUTINE LOAD load_log_kafka ON doris_logs
COLUMNS(time, host, pod_name, container_name, docker_id,log,namespace_name)
PROPERTIES (
"max_batch_interval" = "10",
"max_batch_rows" = "1000000",
"max_batch_size" = "109715200",
"strict_mode" = "false",
"timezone" = "Asia/Shanghai",
"format" = "json"
)
我这里增加 "timezone" = "Asia/Shanghai", 会导致，去掉后，就可以统计
