diff --git a/source/libs/executor/src/executil.c b/source/libs/executor/src/executil.c index 765a3af930..47d3d80b06 100644 --- a/source/libs/executor/src/executil.c +++ b/source/libs/executor/src/executil.c @@ -1457,7 +1457,7 @@ _end: numOfTables = taosArrayGetSize(pUidList); for (int i = 0; i < numOfTables; i++) { void* tmp = taosArrayGet(pUidList, 0); - QUERY_CHECK_NULL(tmp, code, lino, _end, terrno); + QUERY_CHECK_NULL(tmp, code, lino, _error, terrno); STableKeyInfo info = {.uid = *(uint64_t*)tmp, .groupId = 0}; void* p = taosArrayPush(pListInfo->pTableList, &info); diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c index 4fa0bb9e24..b12b621aae 100644 --- a/source/libs/executor/src/scanoperator.c +++ b/source/libs/executor/src/scanoperator.c @@ -3700,6 +3700,7 @@ int32_t createRawScanOperatorInfo(SReadHandle* pHandle, SExecTaskInfo* pTaskInfo SOperatorInfo* pOperator = taosMemoryCalloc(1, sizeof(SOperatorInfo)); if (pInfo == NULL || pOperator == NULL) { code = TSDB_CODE_OUT_OF_MEMORY; + lino = __LINE__; goto _end; } @@ -3718,6 +3719,9 @@ int32_t createRawScanOperatorInfo(SReadHandle* pHandle, SExecTaskInfo* pTaskInfo return code; _end: + if (code != TSDB_CODE_SUCCESS) { + qError("%s failed at line %d since %s", __func__, lino, tstrerror(code)); + } taosMemoryFree(pInfo); taosMemoryFree(pOperator); pTaskInfo->code = code;