fix(test): update test cases.
This commit is contained in:
parent
568b18d4ed
commit
37355b8ae1
|
@ -608,7 +608,7 @@ $loop_count = 0
|
||||||
print step 7
|
print step 7
|
||||||
|
|
||||||
loop4:
|
loop4:
|
||||||
sleep 100
|
sleep 1000
|
||||||
|
|
||||||
$loop_count = $loop_count + 1
|
$loop_count = $loop_count + 1
|
||||||
if $loop_count == 10 then
|
if $loop_count == 10 then
|
||||||
|
|
|
@ -283,7 +283,8 @@ class TDTestCase:
|
||||||
fake.random_int(min=-0, max=32767, step=1) , fake.random_int(min=-0, max=127, step=1) ,
|
fake.random_int(min=-0, max=32767, step=1) , fake.random_int(min=-0, max=127, step=1) ,
|
||||||
fake.pyfloat() , fake.pyfloat() , fake.pystr() , fake.pystr() , ts + i, fake.pystr() , fake.pystr() , fake.pystr() , fake.pystr() , fake.pystr() , fake.pystr() ,
|
fake.pyfloat() , fake.pyfloat() , fake.pystr() , fake.pystr() , ts + i, fake.pystr() , fake.pystr() , fake.pystr() , fake.pystr() , fake.pystr() , fake.pystr() ,
|
||||||
fake.pystr() , fake.pystr() , fake.pystr() , fake.pystr() , fake.pystr() , fake.pystr() , fake.pystr() , fake.pystr() , fake.pystr() , fake.pystr()))
|
fake.pystr() , fake.pystr() , fake.pystr() , fake.pystr() , fake.pystr() , fake.pystr() , fake.pystr() , fake.pystr() , fake.pystr() , fake.pystr()))
|
||||||
|
|
||||||
|
time.sleep(1)
|
||||||
tdSql.query("select count(*) from stable_1;")
|
tdSql.query("select count(*) from stable_1;")
|
||||||
tdSql.checkData(0,0,10*num_random*n)
|
tdSql.checkData(0,0,10*num_random*n)
|
||||||
tdSql.query("select count(*) from hn_table_1_r;")
|
tdSql.query("select count(*) from hn_table_1_r;")
|
||||||
|
@ -291,6 +292,10 @@ class TDTestCase:
|
||||||
|
|
||||||
# stream data check
|
# stream data check
|
||||||
tdCom.check_stream_task_status(stream_name,vgroups,90)
|
tdCom.check_stream_task_status(stream_name,vgroups,90)
|
||||||
|
print("sleep 30s")
|
||||||
|
time.sleep(30)
|
||||||
|
|
||||||
|
print("check--------------------------------------------------------------------------")
|
||||||
tdSql.query("select startts,wend,max_int from stream_max_stable_1 ;")
|
tdSql.query("select startts,wend,max_int from stream_max_stable_1 ;")
|
||||||
tdSql.checkRows(20)
|
tdSql.checkRows(20)
|
||||||
tdSql.query("select sum(max_int) from stream_max_stable_1 ;")
|
tdSql.query("select sum(max_int) from stream_max_stable_1 ;")
|
||||||
|
|
Loading…
Reference in New Issue