fix: downstream free issue
This commit is contained in:
parent
ebcb1e0c36
commit
cd04e9e39d
|
@ -1919,10 +1919,10 @@ _return:
|
||||||
if (pInfo != NULL) {
|
if (pInfo != NULL) {
|
||||||
destroyMergeJoinOperator(pInfo);
|
destroyMergeJoinOperator(pInfo);
|
||||||
}
|
}
|
||||||
|
destroyOperatorAndDownstreams(pOperator, pDownstream, oldNum);
|
||||||
if (newDownstreams) {
|
if (newDownstreams) {
|
||||||
taosMemoryFree(pDownstream);
|
taosMemoryFree(pDownstream);
|
||||||
}
|
}
|
||||||
destroyOperatorAndDownstreams(pOperator, pDownstream, oldNum);
|
|
||||||
pTaskInfo->code = code;
|
pTaskInfo->code = code;
|
||||||
|
|
||||||
return code;
|
return code;
|
||||||
|
|
Loading…
Reference in New Issue