From 930c5d2adf48d05d45b438b4ecfbbda620fbe246 Mon Sep 17 00:00:00 2001 From: Minglei Jin Date: Mon, 17 Jun 2024 08:57:53 +0800 Subject: [PATCH] cleanup wal level 0 before ref removing --- source/libs/wal/src/walMgmt.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/source/libs/wal/src/walMgmt.c b/source/libs/wal/src/walMgmt.c index 219bbd9664..3dbaed1bc7 100644 --- a/source/libs/wal/src/walMgmt.c +++ b/source/libs/wal/src/walMgmt.c @@ -232,13 +232,13 @@ void walClose(SWal *pWal) { pWal->pRefHash = NULL; taosThreadMutexUnlock(&pWal->mutex); - taosRemoveRef(tsWal.refSetId, pWal->refId); - if (pWal->cfg.level == TAOS_WAL_SKIP) { wInfo("vgId:%d, remove all wals, path:%s", pWal->cfg.vgId, pWal->path); taosRemoveDir(pWal->path); taosMkDir(pWal->path); } + + taosRemoveRef(tsWal.refSetId, pWal->refId); } static void walFreeObj(void *wal) {