Merge branch '3.0' into cpwu/3.0
This commit is contained in:
commit
b5734de614
|
@ -408,7 +408,7 @@ class TDTestCase:
|
||||||
|
|
||||||
remaindrowcnt = parameterDict["rowsPerTbl"] * (parameterDict["ctbNum"] - dropTblNum)
|
remaindrowcnt = parameterDict["rowsPerTbl"] * (parameterDict["ctbNum"] - dropTblNum)
|
||||||
|
|
||||||
if not (totalConsumeRows < expectrowcnt and totalConsumeRows > remaindrowcnt):
|
if not (totalConsumeRows <= expectrowcnt and totalConsumeRows >= remaindrowcnt):
|
||||||
tdLog.info("act consume rows: %d, expect consume rows: between %d and %d"%(totalConsumeRows, remaindrowcnt, expectrowcnt))
|
tdLog.info("act consume rows: %d, expect consume rows: between %d and %d"%(totalConsumeRows, remaindrowcnt, expectrowcnt))
|
||||||
tdLog.exit("tmq consume rows error!")
|
tdLog.exit("tmq consume rows error!")
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue