触发流式计算时系统崩溃重启,且没有明确日志

【TDengine 使用环境】
生产环境 /测试/ Poc/预生产环境

【TDengine 版本】

3.3.8.8

【操作系统以及版本】

centos7

【部署方式】容器/非容器部署

【集群节点数】

1

【集群副本数】

1

【描述业务影响】

流式计算触发就崩溃

【问题复现路径/shan】做过哪些操作出现的问题

使用window_count(1) 触发流式计算就崩溃

【遇到的问题:问题现象及影响】

系统崩溃

【资源配置】

【报错完整截图】(不要大段的粘贴报错代码,论坛直接看报错代码不直观)

建了很多类似得流式计算,只有这个触发计算时数据库会直接崩溃,然后重启

是不是必现的?能否向日葵或 todesk 远程看看?

必现,内网环境,无法远程,可以把日志导出来,但是没看出来什么有用得信息

麻烦 show create table 一下创建流用的两个表结构,触发表和计算表

输出create
stable
proj_wsha_sn.glb_identify_purification_hot_total_power
(time timestamp, val double)
tags (fto_id varchar(128),fto_name varchar(128), pur_id varchar(128), pur_name varchar(128));

输入create
stable
proj_wsha_sn.glb_identify_purification_oxy_ele_heat_power
(time timestamp, val double)
tags (fto_id varchar(128),fto_name varchar(128), pur_id varchar(128), pur_name varchar(128), oxy_id varchar(128), oxy_name varchar(128));

大佬还在么?我搞了一台可以连外网得笔记本,可以帮忙远程看一下么?

我本地先试试,稍等

好的大佬,漏了一张计算过程中得表

这个是创建流得语句

create stream proj_wsha_sn.st_b_glb_identify_purification_hot_total_power count_window(1)
from proj_wsha_sn.glb_identify_purification_oxy_ele_heat_power partition by tbname,fto_id,fto_name stream_options(low_latency_calc)
into proj_wsha_sn.glb_identify_purification_hot_total_power output_subtable(concat(‘giphtp_pur’,substr(fto_id,1,1))) tags (fto_id varchar(128) as fto_id,fto_name varchar(128) as fto_name,pur_id varchar(128) as fto_id,pur_name varchar(128) as CONCAT(fto_id,‘纯化’)) as select _twstart as time,o.val+h.val as val from proj_wsha_sn.temp_fto_purification_hyd_ele_heat_power h inner join proj_wsha_sn.glb_identify_purification_oxy_ele_heat_power o on h.fto_id = o.fto_id and h.time = o.time where h.time = _twstart and h.fto_id = %%2;

已复现,谢谢。我们尽快解决

这个能告诉怎么规避么 :joy: ,我要怎么改一改啊

大佬,我这是触发了什么机制了么?我现在要用这个流式计算,我怎么改一改可以凑合用啊,你们发版应该不会很快吧

这块的问题,如果业务上能规避的,可以先别用这个。

我改成这样不崩溃了,但是触发得时候报错了,大佬能帮忙看看么?这个日志没输出全,没看明白

create stream proj_wsha_sn.st_b_b_glb_identify_purification_hot_total_power count_window(1)
from proj_wsha_sn.glb_identify_purification_oxy_ele_heat_power partition by tbname,fto_id,fto_name,pur_id,pur_name stream_options(low_latency_calc)
into proj_wsha_sn.glb_identify_purification_hot_total_power output_subtable(concat(‘giphtp_pur’,replace(fto_id,‘#’,‘’))) tags (fto_id varchar(128) as fto_id,fto_name varchar(128) as fto_name,pur_id varchar(128) as pur_id,pur_name varchar(128) as pur_name) as select _twstart as time,(o.val+h.val) as val from %%tbname o inner join proj_wsha_sn.temp_fto_purification_hyd_ele_heat_power h on h.fto_id = o.fto_id and h.time = o.time where h.time = _twstart;

此话题已在最后回复的 30 天后被自动关闭。不再允许新回复。