From f4df89f7553e12d3775652fcb8b27b87ad4494dc Mon Sep 17 00:00:00 2001
From: liuyao <54liuyao@163.com>
Date: Mon, 10 Jul 2023 11:16:50 +0800
Subject: [PATCH] stream operator checkpoint

---
 source/libs/executor/src/scanoperator.c | 1 -
 1 file changed, 1 deletion(-)

diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index f0d5268b59..73aea04f92 100644
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -2185,7 +2185,6 @@ FETCH_NEXT_BLOCK:
     if (pBlock->info.type == STREAM_CHECKPOINT) {
       streamScanOperatorSaveCheckpoint(pInfo);
       pAPI->stateStore.streamStateCommit(pInfo->pState);
-      pAPI->stateStore.streamStateDeleteCheckPoint(pInfo->pState, pInfo->twAggSup.maxTs - pInfo->twAggSup.deleteMark);
     }
     printDataBlock(pBlock, "stream scan ck");
     return pInfo->pCheckpointRes;