From 1709ab4849548265a9cc465c313e9a01dae9bfee Mon Sep 17 00:00:00 2001 From: dapan1121 Date: Thu, 31 Aug 2023 13:52:37 +0800 Subject: [PATCH] fix: remove constant partition --- source/libs/parser/src/parTranslater.c | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/source/libs/parser/src/parTranslater.c b/source/libs/parser/src/parTranslater.c index 90dfc3a2fd..d2b954a11e 100644 --- a/source/libs/parser/src/parTranslater.c +++ b/source/libs/parser/src/parTranslater.c @@ -3749,10 +3749,6 @@ static int32_t removeConstantValueFromList(SNodeList** pList) { static int32_t translatePartitionBy(STranslateContext* pCxt, SSelectStmt* pSelect) { pCxt->currClause = SQL_CLAUSE_PARTITION_BY; int32_t code = TSDB_CODE_SUCCESS; - - if (pSelect->pPartitionByList) { - code = removeConstantValueFromList(&pSelect->pPartitionByList); - } if (TSDB_CODE_SUCCESS == code && pSelect->pPartitionByList) { int8_t typeType = getTableTypeFromTableNode(pSelect->pFromTable); @@ -3964,6 +3960,11 @@ static int32_t translateSelectFrom(STranslateContext* pCxt, SSelectStmt* pSelect if (TSDB_CODE_SUCCESS == code) { code = replaceTbName(pCxt, pSelect); } + if (TSDB_CODE_SUCCESS == code) { + if (pSelect->pPartitionByList) { + code = removeConstantValueFromList(&pSelect->pPartitionByList); + } + } return code; }