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;