版本:2.1.4
集群规模:3FE+1Obeserver+9BE,均为64C512G10T
问题描述:执行特定查询语句时BE节点宕机,共宕机三台
脱敏后表结构:
create table if not exists test_table (
`key1` date null,
`key2` varchar(32) null,
`key3` bigint null,
...
value1 text null,
...
)engine=ollap
unique key(`key1`, `key2`)
partition by range(`key1`)()
distributed by hash(`key2`) buckets 9
properties(
"replication_allocation" = "tag.location.default:3",
"light_schema_change" = "true",
"dynamic_partition.enable" = "true",
"dynamic_partition.time_unit" = "DAY",
"dynamic_partition.start" = "-7",
"dynamic_partition.end" = "3",
"dynamic_partition.buckets" = "9",
"dynamic_partition.prefix" = "p",
"dynamic_partition.create_history_partition" = "true"
)
执行的查询SQL
with tmp as (
select value1 as value1
from test_table
where key1 = '2025-05-14'
order by key2
limit 60000000
)
select upper(md5(concat_ws('|',case when value1 is null then '' else value 1 end))) as res
from tmp
数据相关信息:value1列存储的是中文字符,有空值,通过avg(length(value1))计算出来的平均值为51,数据量为5700w