fix(query): set correct reader handle.

This commit is contained in:
Haojun Liao 2022-10-29 10:17:41 +08:00
parent 317ee1daea
commit d7f3ddf2dd
1 changed files with 1 additions and 1 deletions

View File

@ -4461,7 +4461,7 @@ static int32_t loadDataBlockFromOneTable(SOperatorInfo* pOperator, STableMergeSc
pCost->totalCheckedRows += pBlock->info.rows;
pCost->loadBlocks += 1;
STsdbReader* reader = taosArrayGetP(pTableScanInfo->dataReaders, readerIdx);
STsdbReader* reader = pTableScanInfo->pReader;
SArray* pCols = tsdbRetrieveDataBlock(reader, NULL);
if (pCols == NULL) {
return terrno;