WangYMDKU

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...