提交 8ab2c31c 编写于 作者: S Shuduo Sang

Merge branch 'feature/sangshuduo/multi-thread-random-test' of...

Merge branch 'feature/sangshuduo/multi-thread-random-test' of https://github.com/taosdata/TDengine into feature/sangshuduo/multi-thread-random-test
...@@ -195,15 +195,16 @@ class Test (threading.Thread): ...@@ -195,15 +195,16 @@ class Test (threading.Thread):
tdDnodes.forcestop(1) tdDnodes.forcestop(1)
tdDnodes.deploy(1) tdDnodes.deploy(1)
tdDnodes.start(1)
tdSql.prepare()
last_tb = "" last_tb = ""
last_stb = "" last_stb = ""
written = 0 written = 0
tdDnodes.start(1)
tdSql.prepare()
def delete_datafiles(self): def delete_datafiles(self):
tdLog.info("delete_data_files") tdLog.info("delete_data_files")
global last_tb global last_tb
global last_stb
global written global written
dnodesDir = tdDnodes.getDnodesRootDir() dnodesDir = tdDnodes.getDnodesRootDir()
...@@ -211,11 +212,12 @@ class Test (threading.Thread): ...@@ -211,11 +212,12 @@ class Test (threading.Thread):
deleteCmd = 'rm -rf %s' % dataDir deleteCmd = 'rm -rf %s' % dataDir
os.system(deleteCmd) os.system(deleteCmd)
last_tb = ""
written = 0
tdDnodes.start(1) tdDnodes.start(1)
# tdLog.sleep(10) # tdLog.sleep(10)
tdSql.prepare() tdSql.prepare()
last_tb = ""
last_stb = ""
written = 0
def run(self): def run(self):
dataOp = { dataOp = {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册