diff --git a/source/libs/executor/src/executor.c b/source/libs/executor/src/executor.c
index 8d2c66ff903006ef62d11d1df93173c5599be7f4..be8bdf73081b7db31fd0168be42fbf10afd63337 100644
--- a/source/libs/executor/src/executor.c
+++ b/source/libs/executor/src/executor.c
@@ -84,15 +84,17 @@ static int32_t doSetStreamBlock(SOperatorInfo* pOperator, void* input, size_t nu
     } else if (type == STREAM_INPUT__DATA_BLOCK) {
       for (int32_t i = 0; i < numOfBlocks; ++i) {
         SSDataBlock* pDataBlock = &((SSDataBlock*)input)[i];
+        taosArrayPush(pInfo->pBlockLists, &pDataBlock);
 
+#if 0
         // TODO optimize
         SSDataBlock* p = createOneDataBlock(pDataBlock, false);
-        /*qError("alloc p i, %d %p", i, p);*/
         p->info = pDataBlock->info;
 
         taosArrayClear(p->pDataBlock);
         taosArrayAddAll(p->pDataBlock, pDataBlock->pDataBlock);
         taosArrayPush(pInfo->pBlockLists, &p);
+#endif
       }
       pInfo->blockType = STREAM_INPUT__DATA_BLOCK;
     } else {
diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index 56fbb21309fe50aa77e20aed71625db58c7eabf2..6c5c33ae29e034add9bb07cea6f98c66dbeec58b 100644
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -920,6 +920,7 @@ _error:
 }
 
 static void doClearBufferedBlocks(SStreamScanInfo* pInfo) {
+#if 0
   if (pInfo->blockType == STREAM_INPUT__DATA_BLOCK) {
     size_t total = taosArrayGetSize(pInfo->pBlockLists);
     for (int32_t i = 0; i < total; i++) {
@@ -928,6 +929,7 @@ static void doClearBufferedBlocks(SStreamScanInfo* pInfo) {
       taosMemoryFree(p);
     }
   }
+#endif
   taosArrayClear(pInfo->pBlockLists);
   pInfo->validBlockIndex = 0;
 #if 0