fix: restore stream code

source/libs/executor/src/executor.c

@@ -109,9 +109,8 @@ static int32_t doSetStreamBlock(SOperatorInfo* pOperator, void* input, size_t nu
 
     SStreamScanInfo* pInfo = pOperator->info;
 
-    if (pInfo->validBlockIndex != 0 || taosArrayGetSize(pInfo->pBlockLists) == 0) {
-      return TSDB_CODE_APP_ERROR;
-    }
+    ASSERT(pInfo->validBlockIndex == 0);
+    ASSERT(taosArrayGetSize(pInfo->pBlockLists) == 0);
 
     if (type == STREAM_INPUT__MERGED_SUBMIT) {
       // ASSERT(numOfBlocks > 1);

source/libs/executor/src/scanoperator.c

@@ -2001,6 +2001,7 @@ FETCH_NEXT_BLOCK:
 
     goto NEXT_SUBMIT_BLK;
   } else {
+    ASSERT(0)
     return NULL;
   }
 }