fix:testcase error

This commit is contained in:
wangmm0220 2023-11-17 15:52:42 +08:00
parent cb9f784c33
commit e7593b4bcf
3 changed files with 13 additions and 13 deletions

View File

@ -20,9 +20,9 @@
,,y,system-test,./pytest.sh python3 ./test.py -f 8-stream/window_close_session_ext.py ,,y,system-test,./pytest.sh python3 ./test.py -f 8-stream/window_close_session_ext.py
,,y,system-test,./pytest.sh python3 ./test.py -f 8-stream/partition_interval.py ,,y,system-test,./pytest.sh python3 ./test.py -f 8-stream/partition_interval.py
,,y,system-test,./pytest.sh python3 ./test.py -f 8-stream/pause_resume_test.py ,,y,system-test,./pytest.sh python3 ./test.py -f 8-stream/pause_resume_test.py
#,,y,system-test,./pytest.sh python3 ./test.py -f 8-stream/vnode_restart.py #,,y,system-test,./pytest.sh python3 ./test.py -f 8-stream/vnode_restart.py -N 4
#,,y,system-test,./pytest.sh python3 ./test.py -f 8-stream/snode_restart.py #,,y,system-test,./pytest.sh python3 ./test.py -f 8-stream/snode_restart.py -N 4
,,y,system-test,./pytest.sh python3 ./test.py -f 8-stream/snode_restart_with_checkpoint.py ,,y,system-test,./pytest.sh python3 ./test.py -f 8-stream/snode_restart_with_checkpoint.py -N 4
,,y,system-test,./pytest.sh python3 ./test.py -f 2-query/tbname_vgroup.py ,,y,system-test,./pytest.sh python3 ./test.py -f 2-query/tbname_vgroup.py
,,y,system-test,./pytest.sh python3 ./test.py -f 2-query/stbJoin.py ,,y,system-test,./pytest.sh python3 ./test.py -f 2-query/stbJoin.py

View File

@ -55,7 +55,7 @@ class TDTestCase:
tdSql.checkData(0, 2, 0) tdSql.checkData(0, 2, 0)
tdSql.query("show dnode 1 variables like '%debugFlag'") tdSql.query("show dnode 1 variables like '%debugFlag'")
tdSql.checkRows(22) tdSql.checkRows(23)
tdSql.query("show dnode 1 variables like '____debugFlag'") tdSql.query("show dnode 1 variables like '____debugFlag'")
tdSql.checkRows(2) tdSql.checkRows(2)

View File

@ -132,14 +132,15 @@ class TDTestCase:
tmqCom.getStartConsumeNotifyFromTmqsim() tmqCom.getStartConsumeNotifyFromTmqsim()
tmqCom.getStartCommitNotifyFromTmqsim() tmqCom.getStartCommitNotifyFromTmqsim()
tdSql.query("select * from information_schema.ins_vnodes") tdSql.query("balance vgroup leader")
# tdLog.debug(tdSql.queryResult) # tdSql.query("select * from information_schema.ins_vnodes")
tdDnodes = cluster.dnodes # # tdLog.debug(tdSql.queryResult)
for result in tdSql.queryResult: # tdDnodes = cluster.dnodes
if result[2] == 'dbt' and result[3] == 'leader': # for result in tdSql.queryResult:
tdLog.debug("leader is %d"%(result[0] - 1)) # if result[2] == 'dbt' and result[3] == 'leader':
tdDnodes[result[0] - 1].stoptaosd() # tdLog.debug("leader is %d"%(result[0] - 1))
break # tdDnodes[result[0] - 1].stoptaosd()
# break
pInsertThread.join() pInsertThread.join()
expectRows = 1 expectRows = 1
@ -158,7 +159,6 @@ class TDTestCase:
tdLog.printNoPrefix("======== test case 1 end ...... ") tdLog.printNoPrefix("======== test case 1 end ...... ")
def run(self): def run(self):
tdSql.prepare()
self.prepareTestEnv() self.prepareTestEnv()
self.tmqCase1() self.tmqCase1()