This commit is contained in:
dapan1121 2021-02-18 10:13:41 +08:00
parent d27fb22759
commit bf077578e8
2 changed files with 2 additions and 2 deletions

View File

@ -2488,7 +2488,7 @@ static void buildTopBotStruct(STopBotInfo *pTopBotInfo, SQLFunctionCtx *pCtx) {
static bool top_bottom_function_setup(SQLFunctionCtx *pCtx) {
if (!function_setup(pCtx)) {
return false;
//return false;
}
STopBotInfo *pInfo = getTopBotOutputInfo(pCtx);

View File

@ -3786,7 +3786,7 @@ void setResultRowOutputBufInitCtx(SQueryRuntimeEnv *pRuntimeEnv, SResultRow *pRe
pCtx->ptsOutputBuf = pRuntimeEnv->pCtx[0].pOutput;
}
if (!pCtx->resultInfo->initialized) {
if (!pCtx->resultInfo->initialized || functionId == TSDB_FUNC_TOP || functionId == TSDB_FUNC_BOTTOM) {
aAggs[functionId].init(pCtx);
}
}