Skip to content

Commit 82f92a5

Browse files
committed
fix mem leak
1 parent f12882a commit 82f92a5

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

source/libs/executor/src/executorInt.c

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1253,6 +1253,8 @@ void freeMergeJoinNotifyOperatorParam(SOperatorParam* pParam) { freeOperatorPara
12531253

12541254
void freeTagScanGetOperatorParam(SOperatorParam* pParam) { freeOperatorParamImpl(pParam, OP_GET_PARAM); }
12551255

1256+
void freeSysScanGetOperatorParam(SOperatorParam* pParam) { freeOperatorParamImpl(pParam, OP_GET_PARAM); }
1257+
12561258
void freeTableScanGetOperatorParam(SOperatorParam* pParam) {
12571259
STableScanOperatorParam* pTableScanParam = (STableScanOperatorParam*)pParam->value;
12581260
taosArrayDestroy(pTableScanParam->pUidList);
@@ -1267,6 +1269,8 @@ void freeTableScanNotifyOperatorParam(SOperatorParam* pParam) { freeOperatorPara
12671269

12681270
void freeTagScanNotifyOperatorParam(SOperatorParam* pParam) { freeOperatorParamImpl(pParam, OP_NOTIFY_PARAM); }
12691271

1272+
void freeSysScanNotifyOperatorParam(SOperatorParam* pParam) { freeOperatorParamImpl(pParam, OP_NOTIFY_PARAM); }
1273+
12701274
void freeOpParamItem(void* pItem) {
12711275
SOperatorParam* pParam = *(SOperatorParam**)pItem;
12721276
pParam->reUse = false;
@@ -1306,6 +1310,9 @@ void freeOperatorParam(SOperatorParam* pParam, SOperatorParamType type) {
13061310
case QUERY_NODE_PHYSICAL_PLAN_TAG_SCAN:
13071311
type == OP_GET_PARAM ? freeTagScanGetOperatorParam(pParam) : freeTagScanNotifyOperatorParam(pParam);
13081312
break;
1313+
case QUERY_NODE_PHYSICAL_PLAN_SYSTABLE_SCAN:
1314+
type == OP_GET_PARAM ? freeSysScanGetOperatorParam(pParam) : freeSysScanNotifyOperatorParam(pParam);
1315+
break;
13091316
default:
13101317
qError("unsupported op %d param, type %d", pParam->opType, type);
13111318
break;

0 commit comments

Comments
 (0)