fix group_key check

This commit is contained in:
Ganlin Zhao 2023-04-28 14:59:35 +08:00
parent 54d82fce8a
commit 76eea9f7c4
1 changed files with 7 additions and 0 deletions

View File

@ -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;