fix: adjust bucket to 40 and exit drop db
This commit is contained in:
parent
a546250239
commit
3309e7b536
|
@ -47,7 +47,7 @@ for test:
|
||||||
|
|
||||||
|
|
||||||
class TDTestCase(TBase):
|
class TDTestCase(TBase):
|
||||||
index = eutil.cpuRand(20) + 1
|
index = eutil.cpuRand(40) + 1
|
||||||
bucketName = f"ci-bucket{index}"
|
bucketName = f"ci-bucket{index}"
|
||||||
updatecfgDict = {
|
updatecfgDict = {
|
||||||
"supportVnodes":"1000",
|
"supportVnodes":"1000",
|
||||||
|
@ -63,6 +63,10 @@ class TDTestCase(TBase):
|
||||||
tdLog.info(f"assign bucketName is {bucketName}\n")
|
tdLog.info(f"assign bucketName is {bucketName}\n")
|
||||||
maxFileSize = (128 + 10) * 1014 * 1024 # add 10M buffer
|
maxFileSize = (128 + 10) * 1014 * 1024 # add 10M buffer
|
||||||
|
|
||||||
|
def exit(self, log):
|
||||||
|
self.dropDb(True)
|
||||||
|
tdLog.exit(log)
|
||||||
|
|
||||||
def insertData(self):
|
def insertData(self):
|
||||||
tdLog.info(f"insert data.")
|
tdLog.info(f"insert data.")
|
||||||
# taosBenchmark run
|
# taosBenchmark run
|
||||||
|
@ -107,8 +111,8 @@ class TDTestCase(TBase):
|
||||||
loop = 0
|
loop = 0
|
||||||
rets = []
|
rets = []
|
||||||
overCnt = 0
|
overCnt = 0
|
||||||
while loop < 200:
|
while loop < 150:
|
||||||
time.sleep(3)
|
time.sleep(2)
|
||||||
|
|
||||||
# check upload to s3
|
# check upload to s3
|
||||||
rets = eos.runRetList(cmd)
|
rets = eos.runRetList(cmd)
|
||||||
|
@ -134,7 +138,7 @@ class TDTestCase(TBase):
|
||||||
|
|
||||||
# check can pass
|
# check can pass
|
||||||
if overCnt > 0:
|
if overCnt > 0:
|
||||||
tdLog.exit(f"s3 have {overCnt} files over size.")
|
self.exit(f"s3 have {overCnt} files over size.")
|
||||||
|
|
||||||
|
|
||||||
def doAction(self):
|
def doAction(self):
|
||||||
|
@ -159,7 +163,7 @@ class TDTestCase(TBase):
|
||||||
return True
|
return True
|
||||||
time.sleep(1)
|
time.sleep(1)
|
||||||
|
|
||||||
tdLog.exit(f"stream count is not expect . expect = 100000 or 100001 real={count} . sql={sql}")
|
self.exit(f"stream count is not expect . expect = 100000 or 100001 real={count} . sql={sql}")
|
||||||
|
|
||||||
|
|
||||||
def checkCreateDb(self, keepLocal, chunkSize, compact):
|
def checkCreateDb(self, keepLocal, chunkSize, compact):
|
||||||
|
|
Loading…
Reference in New Issue