fix: memory leak issue
This commit is contained in:
parent
0ef476a09e
commit
2bd83169bb
|
@ -9327,9 +9327,11 @@ static int32_t addSubtableNameToCreateStreamQuery(STranslateContext* pCxt, SCrea
|
||||||
if (NULL == pStmt->pSubtable) {
|
if (NULL == pStmt->pSubtable) {
|
||||||
return TSDB_CODE_SUCCESS;
|
return TSDB_CODE_SUCCESS;
|
||||||
}
|
}
|
||||||
pSelect->pSubtable = nodesCloneNode(pStmt->pSubtable);
|
|
||||||
if (NULL == pSelect->pSubtable) {
|
if (NULL == pSelect->pSubtable) {
|
||||||
return TSDB_CODE_OUT_OF_MEMORY;
|
pSelect->pSubtable = nodesCloneNode(pStmt->pSubtable);
|
||||||
|
if (NULL == pSelect->pSubtable) {
|
||||||
|
return TSDB_CODE_OUT_OF_MEMORY;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
SRewriteSubtableCxt cxt = {.pCxt = pCxt, .pPartitionList = pSelect->pPartitionByList};
|
SRewriteSubtableCxt cxt = {.pCxt = pCxt, .pPartitionList = pSelect->pPartitionByList};
|
||||||
|
|
Loading…
Reference in New Issue