fix: array push issue

This commit is contained in:
dapan1121 2024-07-29 09:48:04 +08:00
parent 7ccc2d1139
commit 98c6541427
1 changed files with 5 additions and 1 deletions

View File

@ -248,7 +248,11 @@ static int32_t buildExchangeOperatorParam(SOperatorParam** ppRes, int32_t downst
taosMemoryFree(pExc);
return terrno;
}
taosArrayPush(pExc->basic.uidList, pUid);
if (NULL == taosArrayPush(pExc->basic.uidList, pUid)) {
taosArrayDestroy(pExc->basic.uidList);
taosMemoryFree(pExc);
return terrno;
}
(*ppRes)->opType = QUERY_NODE_PHYSICAL_PLAN_EXCHANGE;
(*ppRes)->downstreamIdx = downstreamIdx;