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

Merge pull request #27797 from taosdata/fix/syntax 

fix(stream): remove delay rsp for dispatch
This commit is contained in:
Haojun Liao 2024-09-11 13:44:23 +08:00 committed by GitHub
parent 19ccc5ca9a 6b1e12872f
commit 3d579674b8
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 0 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
tests/system-test/1-insert/database_pre_suf.py
View File

@ -284,7 +284,6 @@ class TDTestCase:
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;")
@ -292,10 +291,6 @@ 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 ;")