From 9f3fabc7f5eaad62bebd259b4faee1a388780508 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao@163.com>
Date: Tue, 13 Dec 2022 09:30:34 +0800
Subject: [PATCH] ci:add some test for stream

---
 tests/script/tsim/stream/basic1.sim | 42 +++++++++++++++++++++++++++++
 1 file changed, 42 insertions(+)

diff --git a/tests/script/tsim/stream/basic1.sim b/tests/script/tsim/stream/basic1.sim
index bb2ea42383..7bf10df637 100644
--- a/tests/script/tsim/stream/basic1.sim
+++ b/tests/script/tsim/stream/basic1.sim
@@ -792,4 +792,46 @@ if $rows != 1 then
   goto loop17
 endi
 
+#for TS-2242
+sql create database test5  vgroups 1;
+sql use test5;
+sql create stable st(ts timestamp, a int, b int , c int) tags(ta int,tb int,tc int);
+sql create table ts1 using st tags(1,1,1);
+sql create stream streams5 trigger at_once into streamt5 as select count(*), _wstart, _wend, max(a) from ts1 interval(10s) ;
+sql create stream streams6 trigger at_once into streamt6 as select count(*), _wstart, _wend, max(a), _wstart as ts from ts1 interval(10s) ;
+
+sql_error create stream streams7 trigger at_once into streamt7 as select _wstart, count(*), _wstart, _wend, max(a) from ts1 interval(10s) ;
+sql_error create stream streams8 trigger at_once into streamt8 as select count(*), _wstart, _wstart, _wend, max(a) from ts1 interval(10s) ;
+sql_error create stream streams9 trigger at_once into streamt9 as select _wstart as ts, count(*), _wstart as ts, _wend, max(a) from ts1 interval(10s) ;
+
+sql insert into ts1 values(1648791211000,1,2,3);
+
+print ====== test _wstart
+
+$loop_count = 0
+
+loop17:
+
+sleep 200
+sql select * from streamt5;
+
+$loop_count = $loop_count + 1
+if $loop_count == 10 then
+  return -1
+endi
+
+if $rows != 1 then
+  print =====rows=$rows
+  goto loop17
+endi
+
+sql select * from streamt6;
+
+if $rows != 1 then
+  print =====rows=$rows
+  goto loop17
+endi
+
+print ====== test _wstart end
+
 system sh/exec.sh -n dnode1 -s stop -x SIGINT