fix(query): fix a typo.

This commit is contained in:
Haojun Liao 2022-07-11 11:28:45 +08:00
parent 4527447b60
commit dd20c34346
1 changed files with 1 additions and 1 deletions

View File

@ -640,7 +640,7 @@ int32_t projectApplyFunctions(SExprInfo* pExpr, SSDataBlock* pResult, SSDataBloc
}
numOfRows = pfCtx->fpSet.process(pfCtx);
} else if (fmIsAggFunc(fmIsAggFunc(pfCtx->functionId))) {
} else if (fmIsAggFunc(pfCtx->functionId)) {
// _group_key function for "partition by tbname" + csum(col_name) query
SColumnInfoData* pOutput = taosArrayGet(pResult->pDataBlock, outputSlotId);
int32_t slotId = pfCtx->param[0].pCol->slotId;