From 4c45f5a01c9d22ac0b6326ee8ef13bc69f9461ba Mon Sep 17 00:00:00 2001
From: liuyao <54liuyao@163.com>
Date: Thu, 26 Oct 2023 14:38:05 +0800
Subject: [PATCH] add ci

---
 tests/script/tsim/stream/windowClose.sim | 82 ++++++++++++++++++++++--
 1 file changed, 78 insertions(+), 4 deletions(-)

diff --git a/tests/script/tsim/stream/windowClose.sim b/tests/script/tsim/stream/windowClose.sim
index 12449526c2..7539164f0c 100644
--- a/tests/script/tsim/stream/windowClose.sim
+++ b/tests/script/tsim/stream/windowClose.sim
@@ -134,7 +134,7 @@ if $rows != 2 then
   goto loop1
 endi
 
-print max delay 2s
+print step 1 max delay 2s
 sql create database test3 vgroups 4;
 sql use test3;
 sql create table t1(ts timestamp, a int, b int , c int, d double);
@@ -165,12 +165,10 @@ if $rows != 2 then
 endi
 
 $now02 = $data02
-
 $now12 = $data12
 
-$loop_count = 0
 
-print max delay 2s......... sleep 5s
+print step1 max delay 2s......... sleep 5s
 sleep 5000
 
 sql select * from streamt13;
@@ -186,6 +184,82 @@ if $data12 != $now12 then
   return -1
 endi
 
+print step 2 max delay 2s
+
+sql create database test4 vgroups 4;
+sql use test4;
+
+sql create stable st(ts timestamp, a int, b int , c int, d double) tags(ta int,tb int,tc int);
+sql create table t1 using st tags(1,1,1);
+sql create table t2 using st tags(2,2,2);
+
+sql create stream stream14 trigger max_delay 2s into streamt14 as select  _wstart, sum(a), now from st partition by tbname interval(10s);
+
+sleep 1000
+
+sql insert into t1 values(1648791213000,1,2,3,1.0);
+sql insert into t1 values(1648791223000,2,2,3,1.1);
+
+sql insert into t2 values(1648791213000,3,2,3,1.0);
+sql insert into t2 values(1648791223000,4,2,3,1.1);
+
+$loop_count = 0
+
+loop3:
+
+sleep 1000
+
+$loop_count = $loop_count + 1
+if $loop_count == 10 then
+  return -1
+endi
+
+sql select * from streamt14 order by 2;
+print $data00 $data01 $data02
+print $data10 $data11 $data12
+print $data20 $data21 $data22
+print $data30 $data31 $data32
+
+if $rows != 4 then
+  print ======rows=$rows
+  goto loop3
+endi
+
+$now02 = $data02
+$now12 = $data12
+$now22 = $data22
+$now32 = $data32
+
+print step2 max delay 2s......... sleep 5s
+sleep 5000
+
+sql select * from streamt14 order by 2;
+print $data00 $data01 $data02
+print $data10 $data11 $data12
+print $data20 $data21 $data22
+print $data30 $data31 $data32
+
+
+if $data02 != $now02 then
+  print ======data02=$data02
+  return -1
+endi
+
+if $data12 != $now12 then
+  print ======data12=$data12
+  return -1
+endi
+
+if $data22 != $now22 then
+  print ======data22=$data22
+  return -1
+endi
+
+if $data32 != $now32 then
+  print ======data32=$data32
+  return -1
+endi
+
 print ======over
 
 system sh/exec.sh -n dnode1 -s stop -x SIGINT