diff --git a/tests/script/tsim/stream/ignoreExpiredData.sim b/tests/script/tsim/stream/ignoreExpiredData.sim index fb6cf2eec6..27920dd539 100644 --- a/tests/script/tsim/stream/ignoreExpiredData.sim +++ b/tests/script/tsim/stream/ignoreExpiredData.sim @@ -52,12 +52,12 @@ sql insert into t1 values(1648791213000,1,2,3,1.0); sql insert into t1 values(1648791223001,1,2,3,1.1); sql insert into t1 values(1648791233002,2,2,3,2.1); sql insert into t1 values(1648791243003,2,2,3,3.1); -sleep 300 +sleep 1000 sql insert into t1 values(1648791200000,4,2,3,4.1); $loop_count = 0 loop1: -sleep 300 +sleep 1000 sql select * from streamt1; $loop_count = $loop_count + 1 @@ -72,7 +72,7 @@ endi $loop_count = 0 loop2: -sleep 300 +sleep 1000 sql select * from streamt2; $loop_count = $loop_count + 1 @@ -87,7 +87,7 @@ endi $loop_count = 0 loop3: -sleep 300 +sleep 1000 sql select * from streamt3; $loop_count = $loop_count + 1 @@ -115,14 +115,16 @@ sql create table ts2 using st tags(2,2,2); sql create stream stream_t1 trigger at_once IGNORE EXPIRED 1 into streamtST1 as select _wstart, count(*) c1, count(a) c2 , sum(a) c3 , max(b) c5, min(c) c6 from st interval(10s) ; sql create stream stream_t2 trigger at_once IGNORE EXPIRED 1 into streamtST2 as select _wstart, count(*) c1, count(a) c2 , sum(a) c3 , max(b) c5, min(c) c6 from st session(ts, 10s) ; sql insert into ts1 values(1648791211000,1,2,3); +sleep 1000 sql insert into ts1 values(1648791222001,2,2,3); -sleep 200 +sleep 1000 sql insert into ts2 values(1648791211000,1,2,3); +sleep 1000 sql insert into ts2 values(1648791222001,2,2,3); $loop_count = 0 loop4: -sleep 300 +sleep 1000 sql select * from streamtST1; $loop_count = $loop_count + 1 @@ -142,7 +144,7 @@ endi $loop_count = 0 loop5: -sleep 300 +sleep 1000 sql select * from streamtST2; $loop_count = $loop_count + 1