From 5463159a3d5a8f56a4f3f08f9864a79c24013c0d Mon Sep 17 00:00:00 2001
From: Ganlin Zhao <ganlinzhao@hotmail.com>
Date: Tue, 13 Sep 2022 18:24:29 +0800
Subject: [PATCH] fix twa function input dup timestamps

---
 source/libs/function/src/builtinsimpl.c | 20 ++++++++++----------
 1 file changed, 10 insertions(+), 10 deletions(-)

diff --git a/source/libs/function/src/builtinsimpl.c b/source/libs/function/src/builtinsimpl.c
index 7d8c231c15..5862a06aac 100644
--- a/source/libs/function/src/builtinsimpl.c
+++ b/source/libs/function/src/builtinsimpl.c
@@ -5446,11 +5446,11 @@ int32_t twaFunction(SqlFunctionCtx* pCtx) {
         }
         numOfElems++;
 
+        INIT_INTP_POINT(st, tsList[i], val[i]);
         if (pInfo->p.key == st.key) {
           return TSDB_CODE_FUNC_DUP_TIMESTAMP;
         }
 
-        INIT_INTP_POINT(st, tsList[i], val[i]);
         pInfo->dOutput += twa_get_area(pInfo->p, st);
         pInfo->p = st;
       }
@@ -5465,11 +5465,11 @@ int32_t twaFunction(SqlFunctionCtx* pCtx) {
         }
         numOfElems++;
 
+        INIT_INTP_POINT(st, tsList[i], val[i]);
         if (pInfo->p.key == st.key) {
           return TSDB_CODE_FUNC_DUP_TIMESTAMP;
         }
 
-        INIT_INTP_POINT(st, tsList[i], val[i]);
         pInfo->dOutput += twa_get_area(pInfo->p, st);
         pInfo->p = st;
       }
@@ -5483,11 +5483,11 @@ int32_t twaFunction(SqlFunctionCtx* pCtx) {
         }
         numOfElems++;
 
+        INIT_INTP_POINT(st, tsList[i], val[i]);
         if (pInfo->p.key == st.key) {
           return TSDB_CODE_FUNC_DUP_TIMESTAMP;
         }
 
-        INIT_INTP_POINT(st, tsList[i], val[i]);
         pInfo->dOutput += twa_get_area(pInfo->p, st);
         pInfo->p = st;
       }
@@ -5501,11 +5501,11 @@ int32_t twaFunction(SqlFunctionCtx* pCtx) {
         }
         numOfElems++;
 
+        INIT_INTP_POINT(st, tsList[i], val[i]);
         if (pInfo->p.key == st.key) {
           return TSDB_CODE_FUNC_DUP_TIMESTAMP;
         }
 
-        INIT_INTP_POINT(st, tsList[i], val[i]);
         pInfo->dOutput += twa_get_area(pInfo->p, st);
         pInfo->p = st;
       }
@@ -5519,11 +5519,11 @@ int32_t twaFunction(SqlFunctionCtx* pCtx) {
         }
         numOfElems++;
 
+        INIT_INTP_POINT(st, tsList[i], val[i]);
         if (pInfo->p.key == st.key) {
           return TSDB_CODE_FUNC_DUP_TIMESTAMP;
         }
 
-        INIT_INTP_POINT(st, tsList[i], val[i]);
         pInfo->dOutput += twa_get_area(pInfo->p, st);
         pInfo->p = st;
       }
@@ -5537,11 +5537,11 @@ int32_t twaFunction(SqlFunctionCtx* pCtx) {
         }
         numOfElems++;
 
+        INIT_INTP_POINT(st, tsList[i], val[i]);
         if (pInfo->p.key == st.key) {
           return TSDB_CODE_FUNC_DUP_TIMESTAMP;
         }
 
-        INIT_INTP_POINT(st, tsList[i], val[i]);
         pInfo->dOutput += twa_get_area(pInfo->p, st);
         pInfo->p = st;
       }
@@ -5555,11 +5555,11 @@ int32_t twaFunction(SqlFunctionCtx* pCtx) {
         }
         numOfElems++;
 
+        INIT_INTP_POINT(st, tsList[i], val[i]);
         if (pInfo->p.key == st.key) {
           return TSDB_CODE_FUNC_DUP_TIMESTAMP;
         }
 
-        INIT_INTP_POINT(st, tsList[i], val[i]);
         pInfo->dOutput += twa_get_area(pInfo->p, st);
         pInfo->p = st;
       }
@@ -5573,11 +5573,11 @@ int32_t twaFunction(SqlFunctionCtx* pCtx) {
         }
         numOfElems++;
 
+        INIT_INTP_POINT(st, tsList[i], val[i]);
         if (pInfo->p.key == st.key) {
           return TSDB_CODE_FUNC_DUP_TIMESTAMP;
         }
 
-        INIT_INTP_POINT(st, tsList[i], val[i]);
         pInfo->dOutput += twa_get_area(pInfo->p, st);
         pInfo->p = st;
       }
@@ -5591,11 +5591,11 @@ int32_t twaFunction(SqlFunctionCtx* pCtx) {
         }
         numOfElems++;
 
+        INIT_INTP_POINT(st, tsList[i], val[i]);
         if (pInfo->p.key == st.key) {
           return TSDB_CODE_FUNC_DUP_TIMESTAMP;
         }
 
-        INIT_INTP_POINT(st, tsList[i], val[i]);
         pInfo->dOutput += twa_get_area(pInfo->p, st);
         pInfo->p = st;
       }
@@ -5609,11 +5609,11 @@ int32_t twaFunction(SqlFunctionCtx* pCtx) {
         }
         numOfElems++;
 
+        INIT_INTP_POINT(st, tsList[i], val[i]);
         if (pInfo->p.key == st.key) {
           return TSDB_CODE_FUNC_DUP_TIMESTAMP;
         }
 
-        INIT_INTP_POINT(st, tsList[i], val[i]);
         pInfo->dOutput += twa_get_area(pInfo->p, st);
         pInfo->p = st;
       }