increase sleep time
This commit is contained in:
parent
f3f0e0a991
commit
ffa25ddd92
|
@ -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
|
||||
|
|
Loading…
Reference in New Issue