From 76eea9f7c49cd6db80f171c5e9521d0780d18528 Mon Sep 17 00:00:00 2001 From: Ganlin Zhao Date: Fri, 28 Apr 2023 14:59:35 +0800 Subject: [PATCH] fix group_key check --- source/libs/executor/src/timesliceoperator.c | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/source/libs/executor/src/timesliceoperator.c b/source/libs/executor/src/timesliceoperator.c index c48b0735fb..7b0da0608a 100644 --- a/source/libs/executor/src/timesliceoperator.c +++ b/source/libs/executor/src/timesliceoperator.c @@ -192,6 +192,11 @@ static bool checkDuplicateTimestamps(STimeSliceOperatorInfo* pSliceInfo, SColumn return false; } +static bool isInterpFunc(SExprInfo* pExprInfo) { + char *name = pExprInfo->pExpr->_function.functionName; + return (strcasecmp(name, "interp") == 0); +} + static bool genInterpolationResult(STimeSliceOperatorInfo* pSliceInfo, SExprSupp* pExprSup, SSDataBlock* pResBlock, bool beforeTs) { int32_t rows = pResBlock->info.rows; @@ -213,6 +218,8 @@ static bool genInterpolationResult(STimeSliceOperatorInfo* pSliceInfo, SExprSupp bool isFilled = true; colDataAppend(pDst, pResBlock->info.rows, (char*)&isFilled, false); continue; + } else if (!isInterpFunc(pExprInfo)) { + continue; } int32_t srcSlot = pExprInfo->base.pParam[0].pCol->slotId;