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

fix: walRetention modify info

This commit is contained in:
Alex Duan 2023-08-23 16:37:36 +08:00
parent f45d1c69b8
commit 2aa47dd191
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
tests/system-test/0-others/walRetention.py
View File

@ -147,13 +147,13 @@ class VNode :
if self.lastVer != -1 and ret: if self.lastVer != -1 and ret:
# first wal file ignore # first wal file ignore
if walFile.startVer == self.firstVer: if walFile.startVer == self.firstVer:
tdLog.info(f" {walFile.pathFile} can del, but is first. snapVer={self.snapVer} firstVer={self.firstVer}") tdLog.info(f" can del {walFile.pathFile}, but is first. snapVer={self.snapVer} firstVer={self.firstVer}")
return False return False
# ver in stay range # ver in stay range
smallVer = self.snapVer - self.walStayRange -1 smallVer = self.snapVer - self.walStayRange -1
if walFile.startVer >= smallVer: if walFile.startVer >= smallVer:
tdLog.info(f" {walFile.pathFile} can del, but range not arrived. snapVer={self.snapVer} smallVer={smallVer}") tdLog.info(f" can del {walFile.pathFile}, but range not arrived. snapVer={self.snapVer} smallVer={smallVer}")
return False return False
return ret return ret
@ -165,14 +165,16 @@ class VNode :
max = -1 max = -1
for walFile in self.walFiles: for walFile in self.walFiles:
if self.canDelete(walFile) == False: if self.canDelete(walFile) == False:
tdLog.info(f" calc vnode size {walFile.pathFile} size={walFile.fsize}") tdLog.info(f" calc vnode size {walFile.pathFile} size={walFile.fsize} startVer={walFile.startVer}")
size += walFile.fsize size += walFile.fsize
if max < walFile.startVer: if max < walFile.startVer:
max = walFile.startVer max = walFile.startVer
lastSize = walFile.fsize lastSize = walFile.fsize
size -= lastSize
tdLog.info(f" last file size need reduct . lastSize={lastSize}") if lastSize > 0:
tdLog.info(f" last file size need reduct . lastSize={lastSize}")
size -= lastSize
return size return size
# vnode # vnode
@ -212,7 +214,7 @@ class VNode :
vnodeSize = self.getWalsSize() vnodeSize = self.getWalsSize()
# need over 20% # need over 20%
if vnodeSize < self.walSize * 1.2: if vnodeSize < self.walSize * 1.2:
tdLog.info(f" wal size valid. {self.path} real = {vnodeSize} set = {self.walSize} need over 20%") tdLog.info(f" wal size valid. {self.path} real = {vnodeSize} set = {self.walSize}. allow over 20%.")
return True return True
# check over # check over