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

test: support replica3 in splited/transform tmqvnode

This commit is contained in:
chenhaoran 2023-10-17 18:30:47 +08:00
parent 6d9732e87a
commit d6579d0498
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tests/system-test/7-tmq/tmqVnodeTransform-stb.py
View File

@ -256,7 +256,7 @@ class TDTestCase:
tdLog.printNoPrefix("======== test case 2 end ...... ") tdLog.printNoPrefix("======== test case 2 end ...... ")
def tmqCaseStableSelect(self): def tmqCaseStableSelect(self):
tdLog.printNoPrefix("======== test case subscrib column start : ") tdLog.printNoPrefix("======== test case 3 subscrib column start : ")
paraDict = {'dbName': 'dbt', paraDict = {'dbName': 'dbt',
'dropFlag': 1, 'dropFlag': 1,
'event': '', 'event': '',
@ -315,7 +315,7 @@ class TDTestCase:
tmqCom.startTmqSimProcess(pollDelay=paraDict['pollDelay'],dbName=paraDict["dbName"],showMsg=paraDict['showMsg'], showRow=paraDict['showRow'],snapshot=paraDict['snapshot']) tmqCom.startTmqSimProcess(pollDelay=paraDict['pollDelay'],dbName=paraDict["dbName"],showMsg=paraDict['showMsg'], showRow=paraDict['showRow'],snapshot=paraDict['snapshot'])
tdLog.info("wait the consume result") tdLog.info("wait the consume result")
time.sleep(5) time.sleep(1)
#restart dnode & remove wal #restart dnode & remove wal
# self.restartAndRemoveWal() # self.restartAndRemoveWal()
@ -332,10 +332,10 @@ class TDTestCase:
for i in range(len(topicNameList)): for i in range(len(topicNameList)):
tdSql.query("drop topic %s"%topicNameList[i]) tdSql.query("drop topic %s"%topicNameList[i])
tdLog.printNoPrefix("======== test case subscrib column end ...... ") tdLog.printNoPrefix("======== test case 3 subscrib column end ...... ")
def tmqCaseDbname(self): def tmqCaseDbname(self):
tdLog.printNoPrefix("======== test case subscrib Dbname start: ") tdLog.printNoPrefix("======== test case 4 subscrib Dbname start: ")
paraDict = {'dbName': 'dbt', paraDict = {'dbName': 'dbt',
'dropFlag': 1, 'dropFlag': 1,
'event': '', 'event': '',
@ -394,7 +394,7 @@ class TDTestCase:
tmqCom.startTmqSimProcess(pollDelay=paraDict['pollDelay'],dbName=paraDict["dbName"],showMsg=paraDict['showMsg'], showRow=paraDict['showRow'],snapshot=paraDict['snapshot']) tmqCom.startTmqSimProcess(pollDelay=paraDict['pollDelay'],dbName=paraDict["dbName"],showMsg=paraDict['showMsg'], showRow=paraDict['showRow'],snapshot=paraDict['snapshot'])
tdLog.info("wait the consume result") tdLog.info("wait the consume result")
time.sleep(5) time.sleep(1)
#restart dnode & remove wal #restart dnode & remove wal
# self.restartAndRemoveWal() # self.restartAndRemoveWal()
@ -411,7 +411,7 @@ class TDTestCase:
for i in range(len(topicNameList)): for i in range(len(topicNameList)):
tdSql.query("drop topic %s"%topicNameList[i]) tdSql.query("drop topic %s"%topicNameList[i])
tdLog.printNoPrefix("======== test case subscrib Dbname end ...... ") tdLog.printNoPrefix("======== test case 4 subscrib Dbname end ...... ")
def run(self): def run(self):
self.prepareTestEnv() self.prepareTestEnv()