test: modify test case

This commit is contained in:
plum-lihui 2022-06-23 20:26:20 +08:00
parent 586d9e4484
commit 52d19df7b2
2 changed files with 3 additions and 4 deletions

View File

@ -13,7 +13,6 @@ from util.cases import *
from util.dnodes import *
from util.common import *
from util.cluster import *
from test import tdDnodes
sys.path.append("./7-tmq")
from tmqCommon import *
@ -165,7 +164,7 @@ class TDTestCase:
else:
break
return
def tmqCase1(self):
tdLog.printNoPrefix("======== test case 1: ")
paraDict = {'dbName': 'db1',
@ -237,7 +236,7 @@ class TDTestCase:
self.check3mnode1off()
tdLog.info("switch end and wait insert data end ................")
pThread.join()
pThread.join()
tdLog.info("check the consume result")
tdSql.query(queryString)

View File

@ -134,4 +134,4 @@ python3 ./test.py -f 7-tmq/schema.py
python3 ./test.py -f 7-tmq/stbFilter.py
python3 ./test.py -f 7-tmq/tmqCheckData.py
python3 ./test.py -f 7-tmq/tmqUdf.py
python3 ./test.py -f 7-tmq/tmq3mnodeSwitch.py -N 5
#python3 ./test.py -f 7-tmq/tmq3mnodeSwitch.py -N 5