TDengine icon indicating copy to clipboard operation
TDengine copied to clipboard

When stream contains aggregate UDF, partition by is must-have

Open WangYMDKU opened this issue 8 months ago • 1 comments

This code works fine: create stream if not exists s11 fill_history 1 watermark 100s into xxx.st11 as select udf_agg_voltage(cells_v) as voltage_corr from xxx.product_property_s_1777158859875520514 where ts>='2024-05-08' partition by tbname count_window(20);

This code does not work: create stream if not exists s11 fill_history 1 watermark 100s into xxx.st11 as select udf_agg_voltage(cells_v) as voltage_corr from xxx.product_property_s_1777158859875520514 where ts>='2024-05-08' count_window(20);

udf_agg_voltage is aggregate UDF. product_property_s_1777158859875520514 is a supertable. version: 3.2.3.0

In documentation, I didn't see any instruction like 'aggregate UDF in stream must work together with partition by'. If so, please add in documentation.

WangYMDKU avatar Jun 05 '24 07:06 WangYMDKU