fix(query): remove invalid code check.

b13e7c15 · Haojun Liao · 8cf3339b · b13e7c15
显示空白变更内容
内联并排

Showing with 6 addition and 4 deletion

source/libs/executor/src/scanoperator.c source/libs/executor/src/scanoperator.c +6 -4

未找到文件。
--- 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);
+  if (pInfo != NULL) {
-  taosMemoryFreeClear(pOperator);
+    destroyTableScanOperatorInfo(pInfo);
+  }
-  pTaskInfo->code = TSDB_CODE_QRY_OUT_OF_MEMORY;
+  taosMemoryFreeClear(pOperator);
+  pTaskInfo->code = code;
  return NULL;
 }