fix(query): add returned code check.

This commit is contained in:
Haojun Liao 2022-07-16 14:05:26 +08:00
parent b4122f8816
commit eeb8709241
1 changed files with 4 additions and 0 deletions

View File

@ -520,6 +520,10 @@ static SSDataBlock* doTableScan(SOperatorInfo* pOperator) {
int32_t code = tsdbReaderOpen(pInfo->readHandle.vnode, &pInfo->cond, tableList, (STsdbReader**)&pInfo->dataReader,
GET_TASKID(pTaskInfo));
if (code != TSDB_CODE_SUCCESS) {
longjmp(pTaskInfo->env, code);
return NULL;
}
}
SSDataBlock* result = doTableScanGroup(pOperator);