From 0ef476a09efa7cac4d9ccb31c80d0b62829fabaa Mon Sep 17 00:00:00 2001 From: dapan1121 Date: Tue, 30 Apr 2024 09:42:53 +0800 Subject: [PATCH] fix: ut issue --- source/libs/parser/src/parTranslater.c | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/source/libs/parser/src/parTranslater.c b/source/libs/parser/src/parTranslater.c index 8740f7c883..06bf0081c3 100644 --- a/source/libs/parser/src/parTranslater.c +++ b/source/libs/parser/src/parTranslater.c @@ -1054,9 +1054,9 @@ static bool isPrimaryKey(STempTableNode* pTable, SNode* pExpr) { static bool hasPkInTable(const STableMeta* pTableMeta) { bool hasPK = pTableMeta->tableInfo.numOfColumns >= 2 && pTableMeta->schema[1].flags & COL_IS_KEY; if (hasPK) { - uInfo("has primary key, %s", pTableMeta->schema[1].name); + uDebug("has primary key, %s", pTableMeta->schema[1].name); } else { - uInfo("no primary key, %s", pTableMeta->schema[1].name); + uDebug("no primary key, %s", pTableMeta->schema[1].name); } return hasPK; } @@ -9327,6 +9327,10 @@ static int32_t addSubtableNameToCreateStreamQuery(STranslateContext* pCxt, SCrea if (NULL == pStmt->pSubtable) { return TSDB_CODE_SUCCESS; } + pSelect->pSubtable = nodesCloneNode(pStmt->pSubtable); + if (NULL == pSelect->pSubtable) { + return TSDB_CODE_OUT_OF_MEMORY; + } SRewriteSubtableCxt cxt = {.pCxt = pCxt, .pPartitionList = pSelect->pPartitionByList}; nodesRewriteExpr(&pSelect->pSubtable, rewriteSubtable, &cxt);