From 45170a73b3da032ef5a76dc749446433fc83705a Mon Sep 17 00:00:00 2001
From: facetosea <25808407@qq.com>
Date: Tue, 21 Nov 2023 19:54:33 +0800
Subject: [PATCH] close file before create in rollback

---
 source/libs/wal/src/walWrite.c | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/source/libs/wal/src/walWrite.c b/source/libs/wal/src/walWrite.c
index a2ca953c59..33d8d34514 100644
--- a/source/libs/wal/src/walWrite.c
+++ b/source/libs/wal/src/walWrite.c
@@ -133,7 +133,8 @@ int32_t walRollback(SWal *pWal, int64_t ver) {
   }
 
   walBuildIdxName(pWal, walGetCurFileFirstVer(pWal), fnameStr);
-  TdFilePtr pIdxFile = pWal->pIdxFile;
+  taosCloseFile(&pWal->pIdxFile);
+  TdFilePtr pIdxFile = taosOpenFile(fnameStr, TD_FILE_WRITE | TD_FILE_READ | TD_FILE_APPEND);
 
   if (pIdxFile == NULL) {
     taosThreadMutexUnlock(&pWal->mutex);
@@ -153,7 +154,8 @@ int32_t walRollback(SWal *pWal, int64_t ver) {
   }
 
   walBuildLogName(pWal, walGetCurFileFirstVer(pWal), fnameStr);
-  TdFilePtr pLogFile = pWal->pLogFile;
+  taosCloseFile(&pWal->pLogFile);
+  TdFilePtr pLogFile = taosOpenFile(fnameStr, TD_FILE_WRITE | TD_FILE_READ | TD_FILE_APPEND);
   wDebug("vgId:%d, wal truncate file %s", pWal->cfg.vgId, fnameStr);
   if (pLogFile == NULL) {
     // TODO
@@ -205,6 +207,9 @@ int32_t walRollback(SWal *pWal, int64_t ver) {
   ((SWalFileInfo *)taosArrayGetLast(pWal->fileInfoSet))->lastVer = ver - 1;
   ((SWalFileInfo *)taosArrayGetLast(pWal->fileInfoSet))->fileSize = entry.offset;
 
+  taosCloseFile(&pIdxFile);
+  taosCloseFile(&pLogFile);
+
   code = walSaveMeta(pWal);
   if (code < 0) {
     wError("vgId:%d, failed to save meta since %s", pWal->cfg.vgId, terrstr());