From b13e7c150d34ec9e0b37e3bec56decff8f41bb07 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Wed, 26 Oct 2022 13:44:53 +0800 Subject: [PATCH] fix(query): remove invalid code check. --- source/libs/executor/src/scanoperator.c | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c index aaf3b96d0f..f65f8a1f68 100644 --- a/source/libs/executor/src/scanoperator.c +++ b/source/libs/executor/src/scanoperator.c @@ -845,7 +845,7 @@ SOperatorInfo* createTableScanOperatorInfo(STableScanPhysiNode* pTableScanNode, if (pInfo->pFilterNode != NULL) { code = filterInitFromNode((SNode*)pInfo->pFilterNode, &pOperator->exprSupp.pFilterInfo, 0); - if (code != TSDB_CODE_OUT_OF_MEMORY) { + if (code != TSDB_CODE_SUCCESS) { goto _error; } } @@ -870,10 +870,12 @@ SOperatorInfo* createTableScanOperatorInfo(STableScanPhysiNode* pTableScanNode, return pOperator; _error: - taosMemoryFreeClear(pInfo); - taosMemoryFreeClear(pOperator); + if (pInfo != NULL) { + destroyTableScanOperatorInfo(pInfo); + } - pTaskInfo->code = TSDB_CODE_QRY_OUT_OF_MEMORY; + taosMemoryFreeClear(pOperator); + pTaskInfo->code = code; return NULL; }