xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Merge pull request #19981 from taosdata/fix/TS-2638-main 

fix:[TS638]diable tsdbReader open in streamScanOperator
This commit is contained in:
Haojun Liao 2023-02-15 10:34:28 +08:00 committed by GitHub
parent b76e20a2b8 6aa44b2fa9
commit a780cf29c9
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
source/libs/executor/src/scanoperator.c
View File

@ -2297,13 +2297,14 @@ SOperatorInfo* createStreamScanOperatorInfo(SReadHandle* pHandle, STableScanPhys
if (pHandle->initTableReader) { if (pHandle->initTableReader) {
pTSInfo->scanMode = TABLE_SCAN__TABLE_ORDER; pTSInfo->scanMode = TABLE_SCAN__TABLE_ORDER;
pTSInfo->base.dataReader = NULL; 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) { if (pHandle->initTqReader) {