From e1134423de098233aa4258acd2b99365fbfc80d1 Mon Sep 17 00:00:00 2001
From: liuyao <54liuyao@163.com>
Date: Mon, 10 Jul 2023 10:22:09 +0800
Subject: [PATCH] stream scan checkpoint

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

diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index dc800dd38b..f8133882c9 100644
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -2185,6 +2185,8 @@ FETCH_NEXT_BLOCK:
       pAPI->stateStore.streamStateCommit(pInfo->pState);
       pAPI->stateStore.streamStateDeleteCheckPoint(pInfo->pState, pInfo->twAggSup.maxTs - pInfo->twAggSup.deleteMark);
     }
+    printDataBlock(pBlock, "stream scan ck");
+    return pBlock;
   }
 
   return NULL;