fix:[TS638]diable tsdbReader open in streamScanOperator

6aa44b2f · wmmhello · 05a9012f · 6aa44b2f
显示空白变更内容
内联并排

Showing with 8 addition and 7 deletion

source/libs/executor/src/scanoperator.c source/libs/executor/src/scanoperator.c +8 -7

未找到文件。
--- 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,
+      pTaskInfo->streamInfo.lastStatus.uid = -1;
-                            &pTSInfo->base.dataReader, NULL);
+//      code = tsdbReaderOpen(pHandle->vnode, &pTSInfo->base.cond, pList, num, pTSInfo->pResBlock,
-      if (code != 0) {
+//                            &pTSInfo->base.dataReader, NULL);
-        terrno = code;
+//      if (code != 0) {
-        destroyTableScanOperatorInfo(pTableScanOp);
+//        terrno = code;
-        goto _error;
+//        destroyTableScanOperatorInfo(pTableScanOp);
-      }
+//        goto _error;
+//      }
    }
    if (pHandle->initTqReader) {