创建流计算报错

开源版问题专区
1

【TDengine 使用环境】
生产环境

【TDengine 版本】

3.3.8.8

【操作系统以及版本】

linux

【部署方式】容器

【集群节点数】

【集群副本数】

【描述业务影响】

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

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

创建超级表1

CREATE STABLE IF NOT EXISTS equ_state (ts TIMESTAMP,status INT) TAGS (code BINARY(25))

创建超级表2

CREATE STABLE IF NOT EXISTS equ_ss (ts TIMESTAMP,run DOUBLE) TAGS (code BINARY(25))

创建流计算，

CREATE STREAM IF NOT EXISTS equ_ss_stream interval(1d) FROM equ_state partition by code

into equ_ss

OUTPUT_SUBTABLE(concat(‘’, code))

as

select

_wstart,

round(sum(case when status = 1 then 1 else 0 end)/60,2) run

from %%tbname

报错内容：

SQL 错误 [9728]: TDengine ERROR (0x2600): sql: CREATE STREAM IF NOT EXISTS equ_data_r.equ_ss_stream interval(1d) FROM equ_data_r.equ_state partition by code
into equ_data_r.equ_ss
OUTPUT_SUBTABLE(concat(‘’, code))
as
select
_wstart,
round(sum(case when status = 1 then 1 else 0 end)/60,2) run
from %%tbname , desc: syntax error near “from equ_data_r.equ_state partition by code
into equ_data_r.equ_ss
output_subtable(concat(‘’, code))
as
select
_wstart,
round(sum(case when status = 1 then 1 else 0 end)/60,2) run
from %%tbname”

【资源配置】

【报错完整截图】（不要大段的粘贴报错代码，论坛直接看报错代码不直观）

2

请将 equ_state 这个表建表语句提供一下，我们在本地环境验证一下。
show create table equ_state\G;

3

这个语句创建的

4

查询后结果如下：CREATE STABLE equ_state (ts TIMESTAMP, status INT) TAGS (code VARCHAR(25))

5

叶工，有没有问题，帮看下

6

收到。我复现试试。

7

OUTPUT_SUBTABLE(concat(‘’, code))： 这个’’是拼一个啥字符？

8 
CREATE STREAM IF NOT EXISTS equ_ss_stream interval(1d) sliding(1d) FROM equ_state partition by tbname, code

into equ_ss

OUTPUT_SUBTABLE(concat('aaa_', code)) tags (code BINARY(25) as code)

as

select

_twstart as ts,

round(sum(case when status = 1 then 1 else 0 end)/60,2) run

from %%tbname;

这个语句可以成功。