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

fix same errors

This commit is contained in:
Ping Xiao 2021-01-26 18:18:04 +08:00
parent 0fb3cf19a2
commit fe31dc0e1f
1 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
tests/pytest/multilevel/fileDistributionSameLevel.py
View File

@ -25,19 +25,19 @@ class TDTestCase:
tdSql.init(conn.cursor(), logSql) tdSql.init(conn.cursor(), logSql)
def run(self): def run(self):
self.ntables = 10 self.ntables = 1000
self.rowsPerTable = 10
self.ts = 1520000010000 self.ts = 1520000010000
tdDnodes.stop(1) tdDnodes.stop(1)
# Test1 1 dataDir # Test1 1 dataDir
cfg={ cfg={
'10' : 'maxVgroupsPerDb', '10' : 'maxVgroupsPerDb',
'100' : 'maxTablesPerVnode',
'/mnt/data00 0 1' : 'dataDir', '/mnt/data00 0 1' : 'dataDir',
'/mnt/data01 0 0' : 'dataDir', '/mnt/data01 0 0' : 'dataDir',
'/mnt/data02 0 0' : 'dataDir', '/mnt/data02 0 0' : 'dataDir',
'/mnt/data03 1 0' : 'dataDir', '/mnt/data03 0 0' : 'dataDir',
'/mnt/data04 1 0' : 'dataDir' '/mnt/data04 0 0' : 'dataDir'
} }
tdSql.createDir('/mnt/data00') tdSql.createDir('/mnt/data00')
tdSql.createDir('/mnt/data01') tdSql.createDir('/mnt/data01')
@ -51,16 +51,17 @@ class TDTestCase:
tdSql.execute("create database test days 1") tdSql.execute("create database test days 1")
tdSql.execute("use test") tdSql.execute("use test")
tdSql.execute("create table tb(ts timestamp, c int)") tdSql.execute("create table stb(ts timestamp, c int) tags(t int)")
for i in range(self.rowsPerTable): for i in range(self.ntables):
tdSql.execute("insert into tb values(%d, 1)" % (self.ts + i * 86400000)) tdSql.execute("create table tb%d using stb tags(%d)" %(i, i))
tdSql.execute("insert into tb%d values(%d, 1)" % (self.ts + int (i / 100) * 86400000))
tdDnodes.stop(1) tdDnodes.stop(1)
tdDnodes.start(1) tdDnodes.start(1)
tdSql.query("select * from test.tb") tdSql.query("select * from test.stb")
tdSql.checkRows(10) tdSql.checkRows(1000)
def stop(self): def stop(self):