From c5171b0c0ea07e4f0fa217c4f0caeba2626560cf Mon Sep 17 00:00:00 2001 From: shenglian zhou Date: Tue, 23 Nov 2021 16:43:52 +0800 Subject: [PATCH] fix bug that change pCtx->param to SDiffInfo field --- src/query/src/qAggMain.c | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/query/src/qAggMain.c b/src/query/src/qAggMain.c index 4e3e1ea8f0..b24036031a 100644 --- a/src/query/src/qAggMain.c +++ b/src/query/src/qAggMain.c @@ -3282,7 +3282,7 @@ static void diff_function(SQLFunctionCtx *pCtx) { } if (pDiffInfo->valueAssigned) { // initial value is not set yet - SET_DOUBLE_VAL(pOutput, pData[i] - pCtx->param[1].dKey); // direct previous may be null + SET_DOUBLE_VAL(pOutput, pData[i] - pDiffInfo->d64Prev); // direct previous may be null *pTimestamp = (tsList != NULL)? tsList[i]:0; pOutput += 1; pTimestamp += 1; @@ -3304,7 +3304,7 @@ static void diff_function(SQLFunctionCtx *pCtx) { } if (pDiffInfo->valueAssigned) { // initial value is not set yet - *pOutput = (float)(pData[i] - pCtx->param[1].dKey); // direct previous may be null + *pOutput = (float)(pData[i] - pDiffInfo->d64Prev); // direct previous may be null *pTimestamp = (tsList != NULL)? tsList[i]:0; pOutput += 1; pTimestamp += 1; @@ -3326,7 +3326,7 @@ static void diff_function(SQLFunctionCtx *pCtx) { } if (pDiffInfo->valueAssigned) { // initial value is not set yet - *pOutput = (int16_t)(pData[i] - pCtx->param[1].i64); // direct previous may be null + *pOutput = (int16_t)(pData[i] - pDiffInfo->i64Prev); // direct previous may be null *pTimestamp = (tsList != NULL)? tsList[i]:0; pOutput += 1; pTimestamp += 1; @@ -3349,7 +3349,7 @@ static void diff_function(SQLFunctionCtx *pCtx) { } if (pDiffInfo->valueAssigned) { // initial value is not set yet - *pOutput = (int8_t)(pData[i] - pCtx->param[1].i64); // direct previous may be null + *pOutput = (int8_t)(pData[i] - pDiffInfo->i64Prev); // direct previous may be null *pTimestamp = (tsList != NULL)? tsList[i]:0; pOutput += 1; pTimestamp += 1; -- GitLab