xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

add ci

This commit is contained in:
54liuyao 2024-08-02 13:57:09 +08:00
parent 1309749c92
commit 2f9490d8bd
5 changed files with 416 additions and 100 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
source/libs/stream/src/tstreamFileState.c
View File

@ -270,6 +270,7 @@ void streamFileStateDestroy(SStreamFileState* pFileState) {
tdListFreeP(pFileState->usedBuffs, destroyRowBuffAllPosPtr); tdListFreeP(pFileState->usedBuffs, destroyRowBuffAllPosPtr);
tdListFreeP(pFileState->freeBuffs, destroyRowBuff); tdListFreeP(pFileState->freeBuffs, destroyRowBuff);
pFileState->stateBuffCleanupFn(pFileState->rowStateBuff); pFileState->stateBuffCleanupFn(pFileState->rowStateBuff);
sessionWinStateCleanup(pFileState->searchBuff);
taosMemoryFree(pFileState); taosMemoryFree(pFileState);
} }

50
tests/script/tsim/stream/streamInterpLinear0.sim
View File

@ -85,12 +85,12 @@ sql insert into t1 values(1648791217001,14,14,14,14.1);
print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(linear); print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(linear);
sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(linear); sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(linear);
print $data00 $data01 $data02 $data03 print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 print $data50 $data51 $data52 $data53 $data54
$loop_count = 0 $loop_count = 0
@ -106,12 +106,12 @@ endi
print 2 sql select * from streamt; print 2 sql select * from streamt;
sql select * from streamt; sql select * from streamt;
print $data00 $data01 $data02 $data03 print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 print $data50 $data51 $data52 $data53 $data54
# row 0 # row 0
@ -152,12 +152,12 @@ sql insert into t1 values(1648791215001,7,7,7,7.1);
print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(linear); print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(linear);
sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(linear); sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(linear);
print $data00 $data01 $data02 $data03 print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 print $data50 $data51 $data52 $data53 $data54
$loop_count = 0 $loop_count = 0
loop3: loop3:
@ -172,12 +172,12 @@ endi
print 3 sql select * from streamt; print 3 sql select * from streamt;
sql select * from streamt; sql select * from streamt;
print $data00 $data01 $data02 $data03 print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 print $data50 $data51 $data52 $data53 $data54
# row 0 # row 0
@ -212,5 +212,5 @@ if $data41 != 13 then
goto loop3 goto loop3
endi endi
print count0 end print end
system sh/exec.sh -n dnode1 -s stop -x SIGINT system sh/exec.sh -n dnode1 -s stop -x SIGINT

132
tests/script/tsim/stream/streamInterpNext0.sim
View File

@ -85,12 +85,12 @@ sql insert into t1 values(1648791217001,4,4,4,4.1);
print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(next); print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(next);
sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(next); sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(next);
print $data00 $data01 $data02 $data03 print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 print $data50 $data51 $data52 $data53 $data54
$loop_count = 0 $loop_count = 0
@ -106,12 +106,12 @@ endi
print 2 sql select * from streamt; print 2 sql select * from streamt;
sql select * from streamt; sql select * from streamt;
print $data00 $data01 $data02 $data03 print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 print $data50 $data51 $data52 $data53 $data54
# row 0 # row 0
@ -152,12 +152,12 @@ sql insert into t1 values(1648791215001,5,5,5,5.1);
print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(next); print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(next);
sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(next); sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(next);
print $data00 $data01 $data02 $data03 print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 print $data50 $data51 $data52 $data53 $data54
$loop_count = 0 $loop_count = 0
loop3: loop3:
@ -172,12 +172,12 @@ endi
print 3 sql select * from streamt; print 3 sql select * from streamt;
sql select * from streamt; sql select * from streamt;
print $data00 $data01 $data02 $data03 print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 print $data50 $data51 $data52 $data53 $data54
# row 0 # row 0
@ -212,5 +212,87 @@ if $data41 != 4 then
goto loop3 goto loop3
endi endi
print count0 end print step2
sql create database test2 vgroups 1;
sql use test2;
sql create table t1(ts timestamp, a int, b int , c int, d double);
sql create stream streams2 trigger at_once IGNORE EXPIRED 0 IGNORE UPDATE 0 into streamt2 as select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 every(1s) fill(next);
run tsim/stream/checkTaskStatus.sim
sql insert into t1 values(1648791212000,0,0,0,0.0) (1648791213001,1,1,1,1.0) (1648791213009,2,2,2,1.1) (1648791215001,5,5,5,5.1) (1648791217001,4,4,4,4.1);
print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(next);
sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(next);
print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 $data54
$loop_count = 0
loop4:
sleep 300
$loop_count = $loop_count + 1
if $loop_count == 10 then
return -1
endi
print 1 sql select * from streamt2;
sql select * from streamt2;
print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 $data54
# row 0
if $rows != 6 then
print ======rows=$rows
goto loop4
endi
# row 0
if $data01 != 0 then
print ======data01=$data01
goto loop4
endi
if $data11 != 1 then
print ======data11=$data11
goto loop4
endi
if $data21 != 5 then
print ======data21=$data21
goto loop4
endi
if $data31 != 5 then
print ======data31=$data31
goto loop4
endi
if $data41 != 4 then
print ======data41=$data41
goto loop4
endi
if $data51 != 4 then
print ======data51=$data51
goto loop4
endi
print end
system sh/exec.sh -n dnode1 -s stop -x SIGINT system sh/exec.sh -n dnode1 -s stop -x SIGINT

129
tests/script/tsim/stream/streamInterpPrev0.sim
View File

@ -85,12 +85,12 @@ sql insert into t1 values(1648791217001,4,4,4,4.1);
print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(prev); print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(prev);
sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(prev); sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(prev);
print $data00 $data01 $data02 $data03 print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 print $data50 $data51 $data52 $data53 $data54
$loop_count = 0 $loop_count = 0
@ -106,12 +106,12 @@ endi
print 2 sql select * from streamt; print 2 sql select * from streamt;
sql select * from streamt; sql select * from streamt;
print $data00 $data01 $data02 $data03 print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 print $data50 $data51 $data52 $data53 $data54
# row 0 # row 0
@ -152,12 +152,12 @@ sql insert into t1 values(1648791215001,5,5,5,5.1);
print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(prev); print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(prev);
sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(prev); sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(prev);
print $data00 $data01 $data02 $data03 print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 print $data50 $data51 $data52 $data53 $data54
$loop_count = 0 $loop_count = 0
loop3: loop3:
@ -172,12 +172,12 @@ endi
print 3 sql select * from streamt; print 3 sql select * from streamt;
sql select * from streamt; sql select * from streamt;
print $data00 $data01 $data02 $data03 print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 print $data50 $data51 $data52 $data53 $data54
# row 0 # row 0
@ -212,5 +212,84 @@ if $data41 != 5 then
goto loop3 goto loop3
endi endi
print count0 end sql create database test2 vgroups 1;
sql use test2;
sql create table t1(ts timestamp, a int, b int , c int, d double);
sql create stream streams2 trigger at_once IGNORE EXPIRED 0 IGNORE UPDATE 0 into streamt2 as select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 every(1s) fill(prev);
run tsim/stream/checkTaskStatus.sim
sql insert into t1 values(1648791212000,0,0,0,0.0) (1648791213001,1,1,1,1.0) (1648791213009,2,2,2,1.1) (1648791215001,5,5,5,5.1) (1648791217001,4,4,4,4.1);
print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(prev);
sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(prev);
print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 $data54
$loop_count = 0
loop4:
sleep 300
$loop_count = $loop_count + 1
if $loop_count == 10 then
return -1
endi
print 1 sql select * from streamt2;
sql select * from streamt2;
print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 $data54
# row 0
if $rows != 6 then
print ======rows=$rows
goto loop4
endi
# row 0
if $data01 != 0 then
print ======data01=$data01
goto loop4
endi
if $data11 != 0 then
print ======data11=$data11
goto loop4
endi
if $data21 != 2 then
print ======data21=$data21
goto loop4
endi
if $data31 != 2 then
print ======data31=$data31
goto loop4
endi
if $data41 != 5 then
print ======data41=$data41
goto loop4
endi
if $data51 != 5 then
print ======data51=$data51
goto loop4
endi
system sh/exec.sh -n dnode1 -s stop -x SIGINT system sh/exec.sh -n dnode1 -s stop -x SIGINT

204
tests/script/tsim/stream/streamInterpValue0.sim
View File

@ -86,12 +86,12 @@ sql insert into t1 values(1648791217001,4,4,4,4.1);
print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(NULL); print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(NULL);
sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(NULL); sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(NULL);
print $data00 $data01 $data02 $data03 print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 print $data50 $data51 $data52 $data53 $data54
$loop_count = 0 $loop_count = 0
@ -107,12 +107,12 @@ endi
print 2 sql select * from streamt; print 2 sql select * from streamt;
sql select * from streamt; sql select * from streamt;
print $data00 $data01 $data02 $data03 print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 print $data50 $data51 $data52 $data53 $data54
# row 0 # row 0
@ -152,12 +152,12 @@ endi
print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(value, 10,20,30,40); print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(value, 10,20,30,40);
sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(value, 10,20,30,40); sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791213000, 1648791217001) every(1s) fill(value, 10,20,30,40);
print $data00 $data01 $data02 $data03 print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 print $data50 $data51 $data52 $data53 $data54
$loop_count = 0 $loop_count = 0
@ -173,12 +173,12 @@ endi
print 2 sql select * from streamt2; print 2 sql select * from streamt2;
sql select * from streamt2; sql select * from streamt2;
print $data00 $data01 $data02 $data03 print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 print $data50 $data51 $data52 $data53 $data54
# row 0 # row 0
@ -357,5 +357,159 @@ if $data14 != 40.000000000 then
goto loop3_1 goto loop3_1
endi endi
print count0 end
print step2
sql create database test2 vgroups 1;
sql use test2;
sql create table t1(ts timestamp, a int, b int , c int, d double);
sql create stream streams3 trigger at_once IGNORE EXPIRED 0 IGNORE UPDATE 0 into streamt3 as select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 every(1s) fill(NULL);
sql create stream streams4 trigger at_once IGNORE EXPIRED 0 IGNORE UPDATE 0 into streamt4 as select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 every(1s) fill(value, 10,20,30,40);
run tsim/stream/checkTaskStatus.sim
sql insert into t1 values(1648791212000,0,0,0,0.0) (1648791213001,1,1,1,1.0) (1648791213009,2,2,2,1.1) (1648791215001,5,5,5,5.1) (1648791217001,4,4,4,4.1);
print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(NULL);
sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(NULL);
print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 $data54
$loop_count = 0
loop4:
sleep 300
$loop_count = $loop_count + 1
if $loop_count == 10 then
return -1
endi
print 1 sql select * from streamt3;
sql select * from streamt3;
print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 $data54
# row 0
if $rows != 6 then
print ======rows=$rows
goto loop4
endi
# row 0
if $data01 != 0 then
print ======data01=$data01
goto loop4
endi
if $data11 != NULL then
print ======data11=$data11
goto loop4
endi
if $data21 != NULL then
print ======data21=$data21
goto loop4
endi
if $data31 != NULL then
print ======data31=$data31
goto loop4
endi
if $data41 != NULL then
print ======data41=$data41
goto loop4
endi
if $data51 != NULL then
print ======data51=$data51
goto loop4
endi
print sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(value, 10,20,30,40);
sql select _irowts, interp(a), interp(b), interp(c), interp(d) from t1 range(1648791212000, 1648791217001) every(1s) fill(value, 10,20,30,40);
print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 $data54
$loop_count = 0
loop4_1:
sleep 300
$loop_count = $loop_count + 1
if $loop_count == 10 then
return -1
endi
print 1 sql select * from streamt4;
sql select * from streamt4;
print $data00 $data01 $data02 $data03 $data04
print $data10 $data11 $data12 $data13 $data14
print $data20 $data21 $data22 $data23 $data24
print $data30 $data31 $data32 $data33 $data34
print $data40 $data41 $data42 $data43 $data44
print $data50 $data51 $data52 $data53 $data54
# row 0
if $rows != 6 then
print ======rows=$rows
goto loop4_1
endi
# row 0
if $data01 != 0 then
print ======data01=$data01
goto loop4_1
endi
if $data11 != 10 then
print ======data11=$data11
goto loop4_1
endi
if $data21 != 10 then
print ======data21=$data21
goto loop4_1
endi
if $data31 != 10 then
print ======data31=$data31
goto loop4_1
endi
if $data41 != 10 then
print ======data41=$data41
goto loop4_1
endi
if $data51 != 10 then
print ======data51=$data51
goto loop4_1
endi
print end
system sh/exec.sh -n dnode1 -s stop -x SIGINT system sh/exec.sh -n dnode1 -s stop -x SIGINT