From 0c1d5f4a4c20ffbc669a2ee30374b8cbc8e7acec Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Mon, 7 Jun 2021 13:10:59 +0800
Subject: [PATCH] [td-225] fix compiler error.

---
 src/query/src/qAggMain.c | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/src/query/src/qAggMain.c b/src/query/src/qAggMain.c
index baef9a57a4..ced83d539b 100644
--- a/src/query/src/qAggMain.c
+++ b/src/query/src/qAggMain.c
@@ -3499,7 +3499,7 @@ static void deriv_function(SQLFunctionCtx *pCtx) {
           }
         }
 
-        pDerivInfo->prevValue = pData[i];
+        pDerivInfo->prevValue = (double) pData[i];
         pDerivInfo->prevTs    = tsList[i];
         notNullElems++;
       }
@@ -3686,7 +3686,7 @@ static void diff_function(SQLFunctionCtx *pCtx) {
         }
 
         if (pCtx->param[1].nType != INITIAL_VALUE_NOT_ASSIGNED) {  // initial value is not set yet
-          *pOutput = (int32_t)(pData[i] - pCtx->param[1].i64);  // direct previous may be null
+          *pOutput = pData[i] - pCtx->param[1].i64;  // direct previous may be null
           *pTimestamp = tsList[i];
           pOutput    += 1;
           pTimestamp += 1;
@@ -3708,13 +3708,13 @@ static void diff_function(SQLFunctionCtx *pCtx) {
         }
 
         if (pCtx->param[1].nType != INITIAL_VALUE_NOT_ASSIGNED) {  // initial value is not set yet
-          *pOutput = (int32_t)(pData[i] - pCtx->param[1].i64);  // direct previous may be null
+          *pOutput = pData[i] - pCtx->param[1].d64;  // direct previous may be null
           *pTimestamp = tsList[i];
           pOutput    += 1;
           pTimestamp += 1;
         }
 
-        pCtx->param[1].i64 = pData[i];
+        pCtx->param[1].d64 = pData[i];
         pCtx->param[1].nType = pCtx->inputType;
         notNullElems++;
       }
@@ -3730,13 +3730,13 @@ static void diff_function(SQLFunctionCtx *pCtx) {
         }
 
         if (pCtx->param[1].nType != INITIAL_VALUE_NOT_ASSIGNED) {  // initial value is not set yet
-          *pOutput = (int32_t)(pData[i] - pCtx->param[1].i64);  // direct previous may be null
+          *pOutput = pData[i] - pCtx->param[1].d64;  // direct previous may be null
           *pTimestamp = tsList[i];
           pOutput    += 1;
           pTimestamp += 1;
         }
 
-        pCtx->param[1].i64 = pData[i];
+        pCtx->param[1].d64 = pData[i];
         pCtx->param[1].nType = pCtx->inputType;
         notNullElems++;
       }
@@ -3752,7 +3752,7 @@ static void diff_function(SQLFunctionCtx *pCtx) {
         }
 
         if (pCtx->param[1].nType != INITIAL_VALUE_NOT_ASSIGNED) {  // initial value is not set yet
-          *pOutput = (int32_t)(pData[i] - pCtx->param[1].i64);  // direct previous may be null
+          *pOutput = (int16_t)(pData[i] - pCtx->param[1].i64);  // direct previous may be null
           *pTimestamp = tsList[i];
           pOutput    += 1;
           pTimestamp += 1;
@@ -3774,7 +3774,7 @@ static void diff_function(SQLFunctionCtx *pCtx) {
         }
 
         if (pCtx->param[1].nType != INITIAL_VALUE_NOT_ASSIGNED) {  // initial value is not set yet
-          *pOutput = (int32_t)(pData[i] - pCtx->param[1].i64);  // direct previous may be null
+          *pOutput = (int8_t)(pData[i] - pCtx->param[1].i64);  // direct previous may be null
           *pTimestamp = tsList[i];
           pOutput    += 1;
           pTimestamp += 1;
-- 
GitLab