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

Merge pull request #22738 from taosdata/TD-25824 

update test case tmqConsumerDiscontinuousData.py to fix the failed oc…
This commit is contained in:
Alex Duan 2023-09-08 09:07:41 +08:00 committed by GitHub
parent f7b23b5427 087fd8289d
commit 3e71208d0f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 15 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -211,6 +211,15 @@ class TDTestCase:
time.sleep(1) time.sleep(1)
continue continue
# write data again when consumer stopped to make sure some data aren't consumed
pInsertDataAgainThread = tmqCom.asyncInsertDataByInterlace(paraDict)
pInsertDataAgainThread.join()
tdLog.info("firstly call to flash database when writing data second time")
tdSql.query("flush database %s"%(paraDict['dbName']))
time.sleep(self.walRetentionPeriod + 1)
tdLog.info("secondely call to flash database when writing data second time")
tdSql.query("flush database %s"%(paraDict['dbName']))
with self.lock: with self.lock:
self.retryPoll = 0 self.retryPoll = 0
currentTime = datetime.now() currentTime = datetime.now()
@ -219,11 +228,10 @@ class TDTestCase:
paraDict["startTs"] = 1640966400000 + paraDict["ctbNum"] * paraDict["rowsPerTbl"] paraDict["startTs"] = 1640966400000 + paraDict["ctbNum"] * paraDict["rowsPerTbl"]
pThread3 = tmqCom.asyncInsertDataByInterlace(paraDict) pThread3 = tmqCom.asyncInsertDataByInterlace(paraDict)
tdLog.debug("wait sub-thread to end insert data") tdLog.debug("wait sub-thread to end insert data")
pThread3.join() pThread3.join()
totalInsertRows = paraDict["ctbNum"] * paraDict["rowsPerTbl"] * 2 totalInsertRows = paraDict["ctbNum"] * paraDict["rowsPerTbl"] * 3
tdLog.debug("wait sub-thread to end consume data") tdLog.debug("wait sub-thread to end consume data")
pThread2.join() pThread2.join()