From cb2757f9673bc79cf67b12a30e95d105ff07161d Mon Sep 17 00:00:00 2001
From: liuyao <54liuyao@163.com>
Date: Mon, 24 Apr 2023 09:52:14 +0800
Subject: [PATCH] fix:fill retrive

---
 source/libs/executor/src/filloperator.c | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/source/libs/executor/src/filloperator.c b/source/libs/executor/src/filloperator.c
index 0ff0c81f80..92782f67fd 100644
--- a/source/libs/executor/src/filloperator.c
+++ b/source/libs/executor/src/filloperator.c
@@ -1258,7 +1258,8 @@ static SSDataBlock* doStreamFill(SOperatorInfo* pOperator) {
           continue;
         } break;
         case STREAM_NORMAL:
-        case STREAM_INVALID: {
+        case STREAM_INVALID: 
+        case STREAM_PULL_DATA: {
           doApplyStreamScalarCalculation(pOperator, pBlock, pInfo->pSrcBlock);
           memcpy(pInfo->pSrcBlock->info.parTbName, pBlock->info.parTbName, TSDB_TABLE_NAME_LEN);
           pInfo->srcRowIndex = 0;
@@ -1267,7 +1268,7 @@ static SSDataBlock* doStreamFill(SOperatorInfo* pOperator) {
           return pBlock;
         } break;
         default:
-          ASSERTS(pBlock->info.type == STREAM_INVALID, "invalid SSDataBlock type");
+          ASSERTS(false, "invalid SSDataBlock type");
       }
     }
 
-- 
GitLab