diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index 8c04492162..12ec7d4201 100644
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -3798,7 +3798,7 @@ FETCH_NEXT_BLOCK:
         QUERY_CHECK_CODE(code, lino, _end);
 
         deletePartName(pInfo, pBlock);
-        pBlock->info.type = STREAM_DELETE_DATA;
+        goto FETCH_NEXT_BLOCK;
       } break;
       case STREAM_CHECKPOINT: {
         qError("stream check point error. msg type: STREAM_INPUT__DATA_BLOCK");