流计算创建报错

开源版问题专区
1

【TDengine 使用环境】
测试环境

【TDengine 版本】

3.3.7.5

【操作系统以及版本】

centos 7

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

docker 容器部署

【集群节点数】

1

【集群副本数】

1

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

流计算创建失败

CREATE STREAM sm1  INTERVAL(5m) SLIDING(5m) 
 FROM ori_data.ori_eq_realtime_data  PARTITION BY tbname 
    INTO 
lnzh_data_cloud.eq_realtime_data AS    
   SELECT      _twstart AS ts,      first(doublevalue) AS doublevalue,     first(strvalue) AS strvalue,      avg(doublevalue) AS avgvalue,      max(doublevalue) AS maxvalue,      min(doublevalue) AS minvalue,    first(psid) psid,first(eqtype) eqtype,first(eqid) eqid, first(datapoint) datapoint FROM ori_data.ori_eq_realtime_data WHERE ts >= _twstart AND ts < _twend;

ori_data.ori_eq_realtime_data 表结构如下：

image
image644×580 19.1 KB

lnzh_data_cloud.eq_realtime_data 表结构如下：

image
image659×631 23.7 KB

【资源配置】

【报错完整截图】

image

2

此问题已解决，

但是现在流计算貌似未触发

create stream sm2 interval(1m) sliding(1m) from `ori_data`.`ori_eq_realtime_data` partition by psid,eqtype,eqid,datapoint,tbname stream_options(max_delay(30s)|watermark(3s)) into `lnzh_data_cloud`.`eq_realtime_data` as select _twstart as ts, first(doublevalue) as doublevalue, first(strvalue) as strvalue, avg(doublevalue) as avgvalue, max(doublevalue) as maxvalue, min(doublevalue) as minvalue from %%tbname where _c0 >= _twstart and _c0 <= _twend;

往 `ori_data`.`ori_eq_realtime_data` 中插入了数据，但是`lnzh_data_cloud`.`eq_realtime_data`表中依旧无数据

3

一直没有数据吗

4

这会出来数据了，是存在一定的延迟吗