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

update test case tmqConsumerDiscontinuousData.py to fix the failed occationally by charles

This commit is contained in:
chao.feng 2023-09-05 14:01:46 +08:00
parent 5dcbae3594
commit 087fd8289d
1 changed files with 15 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -205,12 +205,21 @@ class TDTestCase:
time.sleep(self.walRetentionPeriod + 1)
tdLog.info("secondely call to flash database")
tdSql.query("flush database %s"%(paraDict['dbName']))
# wait the consumer to complete one poll
while (0 == self.retryPoll):
time.sleep(1)
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:
self.retryPoll = 0
currentTime = datetime.now()
@ -218,15 +227,14 @@ class TDTestCase:
paraDict["startTs"] = 1640966400000 + paraDict["ctbNum"] * paraDict["rowsPerTbl"]
pThread3 = tmqCom.asyncInsertDataByInterlace(paraDict)
tdLog.debug("wait sub-thread to end insert data")
pThread3.join()
totalInsertRows = paraDict["ctbNum"] * paraDict["rowsPerTbl"] * 2
totalInsertRows = paraDict["ctbNum"] * paraDict["rowsPerTbl"] * 3
tdLog.debug("wait sub-thread to end consume data")
pThread2.join()
tdLog.info("act consume total rows: %d, act insert total rows: %d"%(self.actConsumeTotalRows, totalInsertRows))
if (self.actConsumeTotalRows >= totalInsertRows):