stream does not generate data

[localvar]

Describe the bug（Bug 描述）

I create a stream but it does not generate any data.

To Reproduce（Bug 复现步骤）

1. create database and measurement

> create database db0
> use db0
> insert cpu,host=server-01,region=east-cn disk=1i,memory=2i,network=3i
> insert cpu,host=server-02,region=east-cn disk=1i,memory=2i,network=3i

2. create stream to count number of data in a 5 minutes interval

> create stream test into db0.autogen.cpu5m on select count(memory) from cpu group by time(5m)
> show streams
+----------+-----------+-------------+------+--------------------+------------+----------------------------+----------+-------+
| database | retention | measurement | Name | source measurement | dimensions |           calls            | interval | delay |
+----------+-----------+-------------+------+--------------------+------------+----------------------------+----------+-------+
| db0      | autogen   | cpu5m       | test | cpu.autogen.cpu    |            | count_memoryAScount_memory | 5m0s     | 0s    |
+----------+-----------+-------------+------+--------------------+------------+----------------------------+----------+-------+
9 columns, 1 rows in set

3. insert some records into the original measurement

> insert cpu,host=server-01,region=south-cn disk=12i,memory=13i,network=14i
> insert cpu,host=server-01,region=south-cn disk=12i,memory=13i,network=14i
> insert cpu,host=server-01,region=south-cn disk=12i,memory=13i,network=14i
...

4. wait 5+ minutes and then check the generated data

> select count(memory) from cpu group by time(5m) order by time desc limit 5
name: cpu
+----------------------+-------+
|         time         | count |
+----------------------+-------+
| 2024-03-05T02:05:00Z |     8 |
| 2024-03-05T02:00:00Z |     2 |
| 2024-03-05T01:55:00Z |     0 |
| 2024-03-05T01:50:00Z |     0 |
| 2024-03-05T01:45:00Z |     0 |
+----------------------+-------+
2 columns, 5 rows in set

> select * from cpu5m
>

Expected behavior（期望结果）

No response

Screenshots（屏幕截图）

No response

Logs（完整的错误日志）

No response

Additional context（其他的一些补充内容）

No response

[localvar]

BTW, there's a typo in the documentation

CREATE STREAM test INTO db0.autogen.cpu1 AS SELECT sum("usage_user") AS "sum_usage_user" FROM "telegraf"."autogen"."cpu" group by time(1m),"cpu","host" delay 20s

should be

CREATE STREAM test INTO db0.autogen.cpu1 ON SELECT sum("usage_user") AS "sum_usage_user" FROM "telegraf"."autogen"."cpu" group by time(1m),"cpu","host" delay 20s

[xiangyu5632]

BTW, there's a typo in the documentation

CREATE STREAM test INTO db0.autogen.cpu1 AS SELECT sum("usage_user") AS "sum_usage_user" FROM "telegraf"."autogen"."cpu" group by time(1m),"cpu","host" delay 20s

should be

CREATE STREAM test INTO db0.autogen.cpu1 ON SELECT sum("usage_user") AS "sum_usage_user" FROM "telegraf"."autogen"."cpu" group by time(1m),"cpu","host" delay 20s

tkx @localvar

[xiangyu5632]

@vicky-run Is there a problem with the stream function?

[vicky-run]

I test this function ok。Are you using the latest version? Or can you add information about the deployment and version?

[localvar]

still not work in my side.
I built openGemini myself from the latest commit: eb39829.
I'm using ts-server in windows wsl2 (ubuntu 20.04).

[localvar]

I tried again in a 3 nodes cluster, it works. so seems this issue only exists in single node mode.
@vicky-run

[vicky-run]

Thanks for your reminder. We will fix this in an upcoming version.