When I create a stream with an interval of more than 1 hour, the SQL statement succeeds but data is not written to the target supertable

[leemb01]

创建流计算：

已创建stream：

创建流式计算的表： 表中存在数据，每条数据间隔1s：

流式计算结果写入的表： 表中无数据：

[yu285]

版本号是？

[leemb01]

3.3.0.0

发自我的iPhone

------------------ 原始邮件 ------------------ 发件人: Yu Chen @.> 发送时间: 2024年5月24日 10:59 收件人: taosdata/TDengine @.> 抄送: leemb01 @.>, Author @.> 主题: Re: [taosdata/TDengine] 创建流式计算，当interval大于1h时，sql执行成功，但未向存储结果的超表写入数据 (Issue #25904)

版本号是？

— Reply to this email directly, view it on GitHub, or unsubscribe. You are receiving this because you authored the thread.Message ID: @.***>

[yu285]

麻烦提供一下建表语句和流式计算的文本吧。

[leemb01]

麻烦提供一下建表语句和流式计算的文本吧。

表和数据是使用taosBenchmark建的 { "filetype": "insert", "cfgdir": "/etc/taos", "host": "192.168.xxx.xxx", "port": 6030, "user": "root", "password": "taosdata", "connection_pool_size": 8, "thread_count": 4, "create_table_thread_count": 4, "result_file": "./insert_res.txt", "confirm_parameter_prompt": "no", "num_of_records_per_req": 10000, "prepared_rand": 10000, "chinese": "no", "escape_character": "yes", "continue_if_fail": "no", "databases": [ { "dbinfo": { "name": "continue_test", "drop": "yes", "vgroups": 4, "precision": "ms" }, "super_tables": [ { "name": "devices", "child_table_exists": "no", "childtable_count": 100, "childtable_prefix": "d", "auto_create_table": "no", "batch_create_tbl_num": 5, "data_source": "rand", "insert_mode": "taosc", "non_stop_mode": "no", "line_protocol": "line", "insert_rows": 640000, "childtable_limit": 0, "childtable_offset": 0, "interlace_rows": 0, "insert_interval": 0, "partial_col_num": 0, "timestamp_step": 1000, "start_timestamp": "2024-04-16 00:00:00.000", "sample_format": "csv", "sample_file": "./sample.csv", "use_sample_ts": "no", "tags_file": "", "columns": [ {"type": "DOUBLE", "name": "current", "count": 1, "max": 100, "min": 1 }, { "type": "INT", "name": "voltage", "max": 200, "min": 1 }, { "type": "FLOAT", "name": "phase", "max": 1, "min": 0 } ], "tags": [ {"type": "TINYINT", "name": "groupid", "max": 10, "min": 1}, {"type": "BINARY", "name": "location", "len": 16, "values": ["San Francisco", "Los Angles", "San Diego", "San Jose", "Palo Alto", "Campbell", "Mountain View", "Sunnyvale", "Santa Clara", "Cupertino"] } ] } ] } ] }

流式计算： create stream if not exists stream_test trigger at_once ignore expired 0 fill_history 1 ignore update 0 into stream_test_data as select _wstart as wstart, _wend as wend, avg(current) as result from d1 interval (2h);