xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix: fix some errors.

This commit is contained in:
Haojun Liao 2024-02-05 09:27:19 +08:00
parent 3533f7ecea
commit f6fea32eeb
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
source/libs/parser/src/parTranslater.c
View File

@ -8209,7 +8209,7 @@ static int32_t createLastTsSelectStmt(char* pDb, char* pTable, STableMeta* pMeta
return code; return code;
} }
code = nodesListAppend((*pSelect1)->pGroupByList, (SNode*)pNode1); code = nodesListAppend((*pSelect1)->pGroupByList, nodesCloneNode((const SNode*)pNode1));
if (code) { if (code) {
return code; return code;
} }
@ -8222,18 +8222,17 @@ static int32_t createLastTsSelectStmt(char* pDb, char* pTable, STableMeta* pMeta
pNode2->groupingSetType = GP_TYPE_NORMAL; pNode2->groupingSetType = GP_TYPE_NORMAL;
pNode2->pParameterList = nodesMakeList(); pNode2->pParameterList = nodesMakeList();
if (NULL == pNode2->pParameterList) { if (NULL == pNode2->pParameterList) {
nodesDestroyNode((SNode*)pNode1); nodesDestroyNode((SNode*)pNode2);
return TSDB_CODE_OUT_OF_MEMORY; return TSDB_CODE_OUT_OF_MEMORY;
} }
code = nodesListAppend(pNode2->pParameterList, (SNode*)pFunc2); code = nodesListAppend(pNode2->pParameterList, nodesCloneNode((const SNode*)pFunc2));
if (code) { if (code) {
nodesDestroyNode((SNode*)pNode2); nodesDestroyNode((SNode*)pNode2);
return code; return code;
} }
code = nodesListAppend((*pSelect1)->pGroupByList, (SNode*)pNode2); return nodesListAppend((*pSelect1)->pGroupByList, (SNode*)pNode2);
return code;
} }
static int32_t buildCreateStreamQuery(STranslateContext* pCxt, SCreateStreamStmt* pStmt, SCMCreateStreamReq* pReq) { static int32_t buildCreateStreamQuery(STranslateContext* pCxt, SCreateStreamStmt* pStmt, SCMCreateStreamReq* pReq) {