【TDengine 使用环境】
测试环境
【TDengine 版本】3.3.8.8 oss
【操作系统以及版本】linux
【部署方式】容器部署
【集群节点数】1
【集群副本数】1
【描述业务影响】采用流计算对指定子表进行统计计算，正常一段时间后，添加包含union all的流计算，td服务持续异常，重启后删除union流又挂掉，再次重启再次挂掉
【资源配置】16G 32C
【报错完整截图】
建流语句：
CREATE STREAM stream_probe.s_union_ck_test
PERIOD(10s)
FROM stream_probe.src_test
PARTITION BY tbname, did
INTO stream_probe.out_union_ck
OUTPUT_SUBTABLE(CONCAT(‘out_union_ck_’, CAST(%%2 AS VARCHAR(32))))
TAGS (
did INT AS %%2
)
AS
SELECT
CAST(_tlocaltime / 1000000 AS TIMESTAMP) AS dts,
CAST(3 AS INT) AS statis_type,
CAST(TO_CHAR(CAST(_tlocaltime / 1000000 AS TIMESTAMP), ‘yyyymmdd’) AS VARCHAR(8)) AS date_tag,
LAST(v) AS v
FROM %%tbname
UNION ALL
SELECT
CAST(_tlocaltime / 1000000 AS TIMESTAMP) AS dts,
CAST(2 AS INT) AS statis_type,
CAST(TO_CHAR(CAST(_tlocaltime / 1000000 AS TIMESTAMP), ‘yyyymmdd’) AS VARCHAR(8)) AS date_tag,
MAX(v) AS v
FROM %%tbname
UNION ALL
SELECT
CAST(_tlocaltime / 1000000 AS TIMESTAMP) AS dts,
CAST(1 AS INT) AS statis_type,
CAST(TO_CHAR(CAST(_tlocaltime / 1000000 AS TIMESTAMP), ‘yyyymmdd’) AS VARCHAR(8)) AS date_tag,
MIN(v) AS v
FROM %%tbname
UNION ALL
SELECT
CAST(_tlocaltime / 1000000 AS TIMESTAMP) AS dts,
CAST(0 AS INT) AS statis_type,
CAST(TO_CHAR(CAST(_tlocaltime / 1000000 AS TIMESTAMP), ‘yyyymmdd’) AS VARCHAR(8)) AS date_tag,
AVG(v) AS v
FROM %%tbname;
