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

fix/TS-5251-add-conflict-check-fix-case

This commit is contained in:
dmchen 2024-11-12 16:54:18 +08:00
parent 830cbf6b2c
commit 93c58252a6
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
tests/system-test/6-cluster/compactDBConflict.py
View File

@ -56,11 +56,7 @@ class TDTestCase:
t2.start() t2.start()
tdLog.info("t2 threading started,wait compact db tran finish") tdLog.info("t2 threading started,wait compact db tran finish")
event2.wait() event2.wait()
rowLen = tdSql.query('show vgroups') tdSql.error('REDISTRIBUTE VGROUP 5 DNODE 1;', expectErrInfo="Transaction not completed due to conflict with compact")
if rowLen > 0:
vgroupId = tdSql.getData(0, 0)
tdLog.info(f"splitVgroupThread vgroupId:{vgroupId}")
tdSql.error('REDISTRIBUTE VGROUP 5 DNODE 1;', expectErrInfo="Transaction not completed due to conflict with compact")
tdLog.info("wait compact db finish") tdLog.info("wait compact db finish")
t2.join() t2.join()
@ -126,6 +122,7 @@ class TDTestCase:
tdLog.info(f"transaction not finished") tdLog.info(f"transaction not finished")
def RedistributeVGroups(self): def RedistributeVGroups(self):
tdLog.info("REDISTRIBUTE VGROUP start")
sql = f"REDISTRIBUTE VGROUP 5 DNODE 1" sql = f"REDISTRIBUTE VGROUP 5 DNODE 1"
tdSql.execute(sql, show=True) tdSql.execute(sql, show=True)
if self.waitTransactionZero() is False: if self.waitTransactionZero() is False:
@ -150,7 +147,7 @@ class TDTestCase:
rowLen = tdSql.query('show vgroups') rowLen = tdSql.query('show vgroups')
if rowLen > 0: if rowLen > 0:
vgroupId = tdSql.getData(0, 0) vgroupId = tdSql.getData(0, 0)
tdLog.debug(f"splitVgroupThread vgroupId:{vgroupId}") tdLog.info(f"splitVgroupThread vgroupId:{vgroupId} start")
tdSql.execute(f"split vgroup {vgroupId}") tdSql.execute(f"split vgroup {vgroupId}")
else: else:
tdLog.exit("get vgroupId fail!") tdLog.exit("get vgroupId fail!")