diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index 48a6c87f19..40ba8572a8 100644
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -1562,6 +1562,7 @@ static SSDataBlock* doQueueScan(SOperatorInfo* pOperator) {
 
     pInfo->tqReader->msg2 = (SPackedSubmit){0};
     pInfo->tqReader->setMsg = 0;
+    pTaskInfo->streamInfo.submit = (SPackedSubmit){0};
     return NULL;
   }