From 819154e1fcce9d87549a47f33edb0644000d055d Mon Sep 17 00:00:00 2001
From: liuyao <54liuyao@163.com>
Date: Wed, 12 Apr 2023 13:47:54 +0800
Subject: [PATCH] use delete_mark to drop check point

---
 source/libs/stream/src/tstreamFileState.c | 12 +-----------
 1 file changed, 1 insertion(+), 11 deletions(-)

diff --git a/source/libs/stream/src/tstreamFileState.c b/source/libs/stream/src/tstreamFileState.c
index ddd8e148ff..9e8fe9b5de 100644
--- a/source/libs/stream/src/tstreamFileState.c
+++ b/source/libs/stream/src/tstreamFileState.c
@@ -313,16 +313,6 @@ SStreamSnapshot* getSnapshot(SStreamFileState* pFileState) {
   return pFileState->usedBuffs;
 }
 
-// void streamFileStateDecode(SStreamFileState* pFileState, void* pBuff, int32_t len) {
-//   pBuff = taosDecodeFixedI64(pBuff, &pFileState->flushMark);
-// }
-
-// void streamFileStateEncode(SStreamFileState* pFileState, void** pVal, int32_t* pLen) {
-//   *pLen = sizeof(TSKEY);
-//   (*pVal) = taosMemoryCalloc(1, *pLen);
-//   void* buff = *pVal;
-//   taosEncodeFixedI64(&buff, pFileState->flushMark);
-// }
 void streamFileStateDecode(TSKEY* key, void* pBuff, int32_t len) { pBuff = taosDecodeFixedI64(pBuff, key); }
 
 void streamFileStateEncode(TSKEY* key, void** pVal, int32_t* pLen) {
@@ -420,7 +410,7 @@ int32_t recoverSnapshot(SStreamFileState* pFileState) {
     TSKEY ts;
     sscanf(val, "%" PRId64 "", &ts);
     taosMemoryFree(val);
-    if (ts < pFileState->flushMark) {
+    if (ts < pFileState->deleteMark) {
       forceRemoveCheckpoint(pFileState, i);
       break;
     } else {
-- 
GitLab