为了更快的定位您的问题,请提供以下信息,谢谢
【详述】执行sql使用date_diff函数嵌套查询be节点全部挂掉
【背景】查询sql
【业务影响】
【StarRocks版本】3.1.2
【集群规模】3fe(1 follower+2observer)+3be(fe与be混部)
【机器信息】CPU虚拟核/内存/网卡,例如:4C/64G/千兆
【联系方式】
【附件】
3.1.2 RELEASE (build 4f3a2ee)
query_id:3476964b-5857-11ee-ba94-525400503db1, fragment_instance:3476964b-5857-11ee-ba94-525400503db6
tracker:process consumption: 28843352
tracker:query_pool consumption: 7526288
tracker:load consumption: 0
tracker:metadata consumption: 8058724
tracker:tablet_metadata consumption: 4835772
tracker:rowset_metadata consumption: 3173440
tracker:segment_metadata consumption: 9222
tracker:column_metadata consumption: 40290
tracker:tablet_schema consumption: 36852
tracker:segment_zonemap consumption: 4842
tracker:short_key_index consumption: 720
tracker:column_zonemap_index consumption: 8050
tracker:ordinal_index consumption: 11504
tracker:bitmap_index consumption: 0
tracker:bloom_filter_index consumption: 0
tracker:compaction consumption: 0
tracker:schema_change consumption: 0
tracker:column_pool consumption: 3252656
tracker:page_cache consumption: 50208
tracker:update consumption: 0
tracker:chunk_allocator consumption: 41168
tracker:clone consumption: 0
tracker:consistency consumption: 0
*** Aborted at 1695284206 (unix time) try “date -d @1695284206” if you are using GNU date ***
PC: @ 0x5494622 starrocks::TimeFunctions::datediff()
*** SIGSEGV (@0x0) received by PID 12992 (TID 0x7f014db32700) from PID 0; stack trace: ***
@ 0x6033302 google::(anonymous namespace)::FailureSignalHandler()
@ 0x7f01c317a630 (unknown)
@ 0x5494622 starrocks::TimeFunctions::datediff()
@ 0x401bc44 starrocks::VectorizedFunctionCallExpr::evaluate_checked()
@ 0x37bced3 starrocks::ExprContext::evaluate()
@ 0x37bd21f starrocks::ExprContext::evaluate()
@ 0x2bf4704 starrocks::pipeline::ProjectOperator::push_chunk()
@ 0x2915ca3 starrocks::pipeline::PipelineDriver::process()
@ 0x534d90e starrocks::pipeline::GlobalDriverExecutor::_worker_thread()
@ 0x4c4df02 starrocks::ThreadPool::dispatch_thread()
@ 0x4c489fa starrocks::supervise_th
建表语句:
CREATE TABLE dw.dwd_trace_logs
(
batch_no VARCHAR(128) not null comment ‘’,
step int comment ‘’,
id VARCHAR(128) not null COMMENT “”,
status int comment ‘’,
trace_time VARCHAR(128) comment ‘’,
message string comment ‘’,
integration_id VARCHAR(100) comment ‘’,
action_info VARCHAR(100) comment ‘’,
strategy_id VARCHAR(100) comment ‘’,
docker_id VARCHAR(100) comment ‘’,
host_ip VARCHAR(100) comment ‘’,
day_partition varchar(100) not null
) ENGINE=OLAP
DUPLICATE KEY (batch_no,step)
PARTITION BY (day_partition)
DISTRIBUTED BY HASH(batch_no,step);
查询语句:
select * from dw.dwd_trace_logs
where batch_no =‘6-2741’;
select t.day_partition as day, t.batch_no,
t.integration_id as integration_id,
t.action_info,
date_diff(‘second’,t.t1_end_time,t.t1_star_time) as t1,
date_diff(‘second’,t.t2_end_time,t.t2_star_time) as t2,
date_diff(‘second’,t.t3_end_time,t.t3_star_time) as t3
from (
select day_partition, batch_no,integration_id,action_info,
max(case when step=101 then trace_time end) as t1_star_time,
max(case when step=103 then trace_time end) as t1_end_time,
max(case when step=201 then trace_time end) as t2_star_time,
max(case when step=203 then trace_time end) as t2_end_time,
max(case when step=301 then trace_time end) as t3_star_time,
max(case when step=302 then trace_time end) as t3_end_time
from dw.dwd_trace_logs
group by day_partition, batch_no,integration_id,action_info
) t;