From 22d92cd3dce06c5202e7c8df3bece27061b09ecf Mon Sep 17 00:00:00 2001
From: Benguang Zhao <bgzhao@taosdata.com>
Date: Thu, 23 Mar 2023 12:55:21 +0800
Subject: [PATCH] feat: WAL cleanup not affected by topic consumption anymore

---
 source/libs/wal/src/walWrite.c | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git a/source/libs/wal/src/walWrite.c b/source/libs/wal/src/walWrite.c
index a8f9362757..848de4f36d 100644
--- a/source/libs/wal/src/walWrite.c
+++ b/source/libs/wal/src/walWrite.c
@@ -290,14 +290,22 @@ int32_t walEndSnapshot(SWal *pWal) {
   int ts = taosGetTimestampSec();
 
   ver = TMAX(ver - pWal->vers.logRetention, pWal->vers.firstVer - 1);
+
+  bool hasTopic = false;
+  int64_t refVer = ver;
   void *pIter = NULL;
   while (1) {
     pIter = taosHashIterate(pWal->pRefHash, pIter);
     if (pIter == NULL) break;
     SWalRef *pRef = *(SWalRef **)pIter;
     if (pRef->refVer == -1) continue;
-    ver = TMIN(ver, pRef->refVer - 1);
+    refVer = TMIN(refVer, pRef->refVer - 1);
     wDebug("vgId:%d, wal found ref %" PRId64 ", refId %" PRId64, pWal->cfg.vgId, pRef->refVer, pRef->refId);
+    hasTopic = true;
+  }
+  // compatible mode
+  if (pWal->cfg.retentionPeriod == 0 && hasTopic) {
+    ver = TMIN(ver, refVer);
   }
 
   int          deleteCnt = 0;