【TDengine 使用环境】
测试环境
【TDengine 版本】
3.3.8.8
【部署方式】 非容器部署
【集群节点数】1
【描述业务影响】
使用流式计算执行统计，问题提过，久了会被淹没，还没得到解决 ，创建表的sql，和创建任务的sql已经贴出，
【遇到的问题：问题现象及影响】
创建流式计算始终过不去
【资源配置】
【报错完整截图】（不要大段的粘贴报错代码，论坛直接看报错代码不直观）
create database if not exists tedi_statistics;
create database if not exists tedi_statistics_h;
-- 订单流水
CREATE TABLE `tedi_statistics`.u_user_pay_order (
ts TIMESTAMP,
order_num BIGINT COMPOSITE KEY,
title nchar(32),
shop_name nchar(64),
user_id bigint,
shop_id bigint,
success TINYINT ,
trade_status TINYINT ,
order_amount int,
receipt_amount int,
buyer_pay_amount int
) tags(merchant_id bigint );
-- 小时统计
CREATE TABLE tedi_statistics_h.st_merchant_order_h (
ts TIMESTAMP, -- 时间戳作为主键
shop_id BIGINT COMPOSITE key, -- 店铺ID
order_count INT, -- 订单量
total_amount INT
)
TAGS (
merchant_id BIGINT
);
CREATE STREAM str_user_pay_order_mer_per_h
PERIOD(1h, 5m)
INTO tedi_statistics_h.st_merchant_order_h
OUTPUT_SUBTABLE(concat('st_merchant_order_h_', %%1))
(ts, shop_id COMPOSITE KEY, order_count)
TAGS(merchant_id bigint)
AS
SELECT
TIMETRUNCATE(now(), 1h, 1) AS ts,
shop_id,
COUNT(1) AS order_count
FROM `tedi_statistics`.u_user_pay_order
WHERE ts >= TIMETRUNCATE(now() - 1h, 1h, 1)
AND ts < TIMETRUNCATE(now(), 1h, 1)
AND trade_status = 2
PARTITION BY merchant_id,shop_id