diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index 6ce161560a36d2879250a35dd23ce3329319dcf5..b556733254ae96ae4c7aac2005bd5116d53d6846 100644
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -2297,13 +2297,14 @@ SOperatorInfo* createStreamScanOperatorInfo(SReadHandle* pHandle, STableScanPhys
     if (pHandle->initTableReader) {
       pTSInfo->scanMode = TABLE_SCAN__TABLE_ORDER;
       pTSInfo->base.dataReader = NULL;
-      code = tsdbReaderOpen(pHandle->vnode, &pTSInfo->base.cond, pList, num, pTSInfo->pResBlock,
-                            &pTSInfo->base.dataReader, NULL);
-      if (code != 0) {
-        terrno = code;
-        destroyTableScanOperatorInfo(pTableScanOp);
-        goto _error;
-      }
+      pTaskInfo->streamInfo.lastStatus.uid = -1;
+//      code = tsdbReaderOpen(pHandle->vnode, &pTSInfo->base.cond, pList, num, pTSInfo->pResBlock,
+//                            &pTSInfo->base.dataReader, NULL);
+//      if (code != 0) {
+//        terrno = code;
+//        destroyTableScanOperatorInfo(pTableScanOp);
+//        goto _error;
+//      }
     }
 
     if (pHandle->initTqReader) {