refactor: support submitreq2

2022-12-07 19:06:16 +08:00 · 2022-12-07 19:06:16 +08:00 · 25df820419
parent 9e5274df99
commit 25df820419
1 changed files with 1 additions and 0 deletions
--- 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;
  }