From dd734a0565d2180c03c1b0cef4d7cec8b7e8299e Mon Sep 17 00:00:00 2001 From: dapan1121 Date: Thu, 11 Nov 2021 09:14:57 +0800 Subject: [PATCH] fix compile issue --- src/query/src/qExecutor.c | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c index 077d00e410..b2282f3cc3 100644 --- a/src/query/src/qExecutor.c +++ b/src/query/src/qExecutor.c @@ -5958,6 +5958,7 @@ static bool doEveryInterpolation(SOperatorInfo* pOperatorInfo, SSDataBlock* pBlo SQueryAttr* pQueryAttr = pRuntimeEnv->pQueryAttr; bool ascQuery = QUERY_IS_ASC_QUERY(pQueryAttr); int32_t gidx = pRuntimeEnv->current->groupIndex; + SQLFunctionCtx* pCtx = NULL; *needApply = false; @@ -5967,8 +5968,6 @@ static bool doEveryInterpolation(SOperatorInfo* pOperatorInfo, SSDataBlock* pBlo assert(pOperatorInfo->numOfOutput > 1); - SQLFunctionCtx* pCtx = NULL; - for (int32_t i = 1; i < pOperatorInfo->numOfOutput; ++i) { assert(pEveryInfo->binfo.pCtx[i].functionId == TSDB_FUNC_INTERP || pEveryInfo->binfo.pCtx[i].functionId == TSDB_FUNC_TS_DUMMY @@ -6171,10 +6170,12 @@ group_finished_exit: pEveryInfo->groupDone = true; - pCtx->startTs = INT64_MIN; - pCtx->start.key = INT64_MIN; - pCtx->end.key = INT64_MIN; - + if (pCtx) { + pCtx->startTs = INT64_MIN; + pCtx->start.key = INT64_MIN; + pCtx->end.key = INT64_MIN; + } + return true; } -- GitLab