流计算无法指定列作为时间窗口划分的列

开源版问题专区
1

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

【TDengine 版本】

3.3.6

【操作系统以及版本】

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

非容器部署

【集群节点数】

3

【集群副本数】

3

【描述业务影响】

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

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

进行流计算时，进行窗口划分的列默认是第一列，但是我想指定其他列作为我的划分列。尝试使用子查询依旧无效

【资源配置】

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

2

提供的信息太少了，无法回答。

请将 创建流的语句发出来看看。或将表的schema发出来，然后再说一下你的需求。

3

CREATE STREAM stream_equipment_daily_power
TRIGGER AT_ONCE
WATERMARK 1000s
IGNORE EXPIRED 0
INTO equipment_daily_power
SUBTABLE(equipment_code)
AS
SELECT
_wstart AS starttime,
equipment_code,
MAX(CAST(item_value AS FLOAT)) - MIN(CAST(item_value AS FLOAT)) AS power_consumption,
_wend AS update_time
FROM
table1
WHERE
item_desc IN (‘电量显示值’, ‘电表显示值’, ‘累计用电量’)
AND item_value IS NOT NULL
AND item_value != ‘’
PARTITION BY equipment_code
INTERVAL(1d);
上述是创建流计算的语句

table1的第一个字段是time1,目前窗口是根据time1的值进行划分。但是实际业务可能使用表中的另一个字段time2进行划分窗口

4

请不要在 3.3.6.x版本使用流计算，我们在3.3.8.x版本重构了流计算模块，做了非常大的修改，包括语法和灵活性。请升级到 3.3.8.x 版本后验证流计算功能吧。