fix(query):check return code

This commit is contained in:
Haojun Liao 2024-08-06 14:05:46 +08:00
parent c8dd0e90a9
commit 2f1b353fea
1 changed files with 7 additions and 6 deletions

View File

@ -1554,16 +1554,17 @@ int32_t getTableListInfo(const SExecTaskInfo* pTaskInfo, SArray** pList) {
return TSDB_CODE_INVALID_PARA; return TSDB_CODE_INVALID_PARA;
} }
*pList = NULL;
SArray* pArray = taosArrayInit(0, POINTER_BYTES); SArray* pArray = taosArrayInit(0, POINTER_BYTES);
if (pArray == NULL) { if (pArray == NULL) {
return TSDB_CODE_OUT_OF_MEMORY; return terrno;
} }
SOperatorInfo* pOperator = pTaskInfo->pRoot; int32_t code = extractTableList(pArray, pTaskInfo->pRoot);
extractTableList(pArray, pOperator); if (code == 0) {
*pList = pArray; *pList = pArray;
return TSDB_CODE_SUCCESS; }
return code;
} }
int32_t qStreamOperatorReleaseState(qTaskInfo_t tInfo) { int32_t qStreamOperatorReleaseState(qTaskInfo_t tInfo) {