未验证 提交 ae95c97b 编写于 作者: H Haojun Liao 提交者: GitHub

Merge pull request #19977 from taosdata/fix/TS-2638

fix:[TS638]diable tsdbReader open in streamScanOperator
...@@ -1273,7 +1273,7 @@ static int32_t smlInsertData(SSmlHandle *info) { ...@@ -1273,7 +1273,7 @@ static int32_t smlInsertData(SSmlHandle *info) {
} }
static void smlPrintStatisticInfo(SSmlHandle *info) { static void smlPrintStatisticInfo(SSmlHandle *info) {
uError( uDebug(
"SML:0x%" PRIx64 "SML:0x%" PRIx64
" smlInsertLines result, code:%d,lineNum:%d,stable num:%d,ctable num:%d,create stable num:%d,alter stable tag num:%d,alter stable col num:%d \ " smlInsertLines result, code:%d,lineNum:%d,stable num:%d,ctable num:%d,create stable num:%d,alter stable tag num:%d,alter stable col num:%d \
parse cost:%" PRId64 ",schema cost:%" PRId64 ",bind cost:%" PRId64 ",rpc cost:%" PRId64 ",total cost:%" PRId64 parse cost:%" PRId64 ",schema cost:%" PRId64 ",bind cost:%" PRId64 ",rpc cost:%" PRId64 ",total cost:%" PRId64
......
...@@ -2304,13 +2304,14 @@ SOperatorInfo* createStreamScanOperatorInfo(SReadHandle* pHandle, STableScanPhys ...@@ -2304,13 +2304,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) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册