From 184b2d64f7189d80750155e79d916f6346826d1d Mon Sep 17 00:00:00 2001
From: liuyao <54liuyao@163.com>
Date: Tue, 11 Jul 2023 09:18:17 +0800
Subject: [PATCH] scan op state

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

diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index 5ea879383d..7d74632c1d 100644
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -1775,6 +1775,7 @@ void streamScanOperatorSaveCheckpoint(SStreamScanInfo* pInfo) {
   int32_t len = streamScanOperatorEncode(pInfo, &pBuf);
   pInfo->stateStore.streamStateSaveInfo(pInfo->pState, STREAM_SCAN_OP_CHECKPOINT_NAME, strlen(STREAM_SCAN_OP_CHECKPOINT_NAME), pBuf, len);
   taosMemoryFree(pBuf);
+  pInfo->stateStore.streamStateCommit(pInfo->pState);
 }
 
 // other properties are recovered from the execution plan
@@ -2188,7 +2189,6 @@ FETCH_NEXT_BLOCK:
 
     if (pBlock->info.type == STREAM_CHECKPOINT) {
       streamScanOperatorSaveCheckpoint(pInfo);
-      pAPI->stateStore.streamStateCommit(pInfo->pState);
     }
     printDataBlock(pBlock, "stream scan ck");
     return pInfo->pCheckpointRes;