From 48437191ee08f9c17a5669e9f088ad1e5d405cba Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Thu, 19 Dec 2024 16:26:17 +0800
Subject: [PATCH 01/13] fix(analytics): fix check return value error.

---
 source/util/src/tanalytics.c | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/source/util/src/tanalytics.c b/source/util/src/tanalytics.c
index 68bbbb7e99..3812295381 100644
--- a/source/util/src/tanalytics.c
+++ b/source/util/src/tanalytics.c
@@ -478,11 +478,13 @@ static int32_t taosAnalJsonBufWriteStrUseCol(SAnalyticBuf *pBuf, const char *buf
   }
 
   if (pBuf->bufType == ANALYTICS_BUF_TYPE_JSON) {
-    if (taosWriteFile(pBuf->filePtr, buf, bufLen) != bufLen) {
+    int32_t ret = taosWriteFile(pBuf->filePtr, buf, bufLen);
+    if (ret < 0) {
       return terrno;
     }
   } else {
-    if (taosWriteFile(pBuf->pCols[colIndex].filePtr, buf, bufLen) != bufLen) {
+    int32_t ret = taosWriteFile(pBuf->pCols[colIndex].filePtr, buf, bufLen);
+    if (ret < 0) {
       return terrno;
     }
   }

From 4d008308b8b176a605fd2611124c25215a26590a Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Fri, 20 Dec 2024 18:49:57 +0800
Subject: [PATCH 02/13] refactor(analytics): do some refactor.

---
 source/util/src/tanalytics.c | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/source/util/src/tanalytics.c b/source/util/src/tanalytics.c
index 3812295381..306795f5ed 100644
--- a/source/util/src/tanalytics.c
+++ b/source/util/src/tanalytics.c
@@ -479,12 +479,12 @@ static int32_t taosAnalJsonBufWriteStrUseCol(SAnalyticBuf *pBuf, const char *buf
 
   if (pBuf->bufType == ANALYTICS_BUF_TYPE_JSON) {
     int32_t ret = taosWriteFile(pBuf->filePtr, buf, bufLen);
-    if (ret < 0) {
+    if (ret != bufLen) {
       return terrno;
     }
   } else {
     int32_t ret = taosWriteFile(pBuf->pCols[colIndex].filePtr, buf, bufLen);
-    if (ret < 0) {
+    if (ret != bufLen) {
       return terrno;
     }
   }

From 59003022d8788c09608f3bd39e8b811fa579ae9e Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Mon, 23 Dec 2024 14:32:04 +0800
Subject: [PATCH 03/13] fix(analytics):copy the correct post rsp.

---
 source/util/src/tanalytics.c | 22 +++++++++++++++++++---
 1 file changed, 19 insertions(+), 3 deletions(-)

diff --git a/source/util/src/tanalytics.c b/source/util/src/tanalytics.c
index 306795f5ed..5a3ceef422 100644
--- a/source/util/src/tanalytics.c
+++ b/source/util/src/tanalytics.c
@@ -216,12 +216,28 @@ static size_t taosCurlWriteData(char *pCont, size_t contLen, size_t nmemb, void
     return 0;
   }
 
-  pRsp->dataLen = (int64_t)contLen * (int64_t)nmemb;
-  pRsp->data = taosMemoryMalloc(pRsp->dataLen + 1);
+  int64_t size = pRsp->dataLen + (int64_t)contLen * nmemb;
+  if (pRsp->data == NULL) {
+    pRsp->data = taosMemoryMalloc(size + 1);
+    if (pRsp->data == NULL) {
+      uError("failed to prepare recv buffer for post rsp, len:%d, code:%s", (int32_t) size + 1, tstrerror(terrno));
+      return terrno;
+    }
+  } else {
+    char* p = taosMemoryRealloc(pRsp->data, size + 1);
+    if (p == NULL) {
+      uError("failed to prepare recv buffer for post rsp, len:%d, code:%s", (int32_t) size + 1, tstrerror(terrno));
+      return terrno;
+    }
+
+    pRsp->data = p;
+  }
 
   if (pRsp->data != NULL) {
-    (void)memcpy(pRsp->data, pCont, pRsp->dataLen);
+    (void)memcpy(pRsp->data + pRsp->dataLen, pCont, pRsp->dataLen);
     pRsp->data[pRsp->dataLen] = 0;
+    pRsp->dataLen = size;
+
     uDebugL("curl response is received, len:%" PRId64 ", content:%s", pRsp->dataLen, pRsp->data);
     return pRsp->dataLen;
   } else {

From 0beaecc5d6dd92740f2f45784424f796362d47b1 Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Mon, 23 Dec 2024 16:41:50 +0800
Subject: [PATCH 04/13] fix(analytics): fix bugs in recv post results.

---
 source/util/src/tanalytics.c | 19 +++++++++++--------
 1 file changed, 11 insertions(+), 8 deletions(-)

diff --git a/source/util/src/tanalytics.c b/source/util/src/tanalytics.c
index 5a3ceef422..e68edd4b76 100644
--- a/source/util/src/tanalytics.c
+++ b/source/util/src/tanalytics.c
@@ -216,30 +216,33 @@ static size_t taosCurlWriteData(char *pCont, size_t contLen, size_t nmemb, void
     return 0;
   }
 
-  int64_t size = pRsp->dataLen + (int64_t)contLen * nmemb;
+  int64_t newDataSize = (int64_t) contLen * nmemb;
+  int64_t size = pRsp->dataLen + newDataSize;
+
   if (pRsp->data == NULL) {
     pRsp->data = taosMemoryMalloc(size + 1);
     if (pRsp->data == NULL) {
       uError("failed to prepare recv buffer for post rsp, len:%d, code:%s", (int32_t) size + 1, tstrerror(terrno));
-      return terrno;
+      return 0;   // return the recv length, if failed, return 0
     }
   } else {
     char* p = taosMemoryRealloc(pRsp->data, size + 1);
     if (p == NULL) {
       uError("failed to prepare recv buffer for post rsp, len:%d, code:%s", (int32_t) size + 1, tstrerror(terrno));
-      return terrno;
+      return 0;   // return the recv length, if failed, return 0
     }
 
     pRsp->data = p;
   }
 
   if (pRsp->data != NULL) {
-    (void)memcpy(pRsp->data + pRsp->dataLen, pCont, pRsp->dataLen);
-    pRsp->data[pRsp->dataLen] = 0;
-    pRsp->dataLen = size;
+    (void)memcpy(pRsp->data + pRsp->dataLen, pCont, newDataSize);
 
-    uDebugL("curl response is received, len:%" PRId64 ", content:%s", pRsp->dataLen, pRsp->data);
-    return pRsp->dataLen;
+    pRsp->dataLen = size;
+    pRsp->data[size] = 0;
+
+    uDebugL("curl response is received, len:%" PRId64 ", content:%s", size, pRsp->data);
+    return newDataSize;
   } else {
     pRsp->dataLen = 0;
     uError("failed to malloc curl response");

From 4bc4894d7c6ce7f793e19b9cf1f751dfbda9b8b9 Mon Sep 17 00:00:00 2001
From: Jing Sima <simondominic9997@outlook.com>
Date: Mon, 23 Dec 2024 14:13:00 +0800
Subject: [PATCH 05/13] fix:[TS-5798] Fix crash when function's param num more
 than 127.

---
 .../14-reference/03-taos-sql/10-function.md   |  1 +
 .../14-reference/03-taos-sql/10-function.md   |  1 +
 source/libs/function/src/builtins.c           | 10 ++++-
 .../army/query/function/test_func_paramnum.py | 42 +++++++++++++++++++
 tests/parallel_test/cases.task                |  1 +
 5 files changed, 53 insertions(+), 2 deletions(-)
 create mode 100644 tests/army/query/function/test_func_paramnum.py

diff --git a/docs/en/14-reference/03-taos-sql/10-function.md b/docs/en/14-reference/03-taos-sql/10-function.md
index e6cfa20bd4..ab5c48bce2 100644
--- a/docs/en/14-reference/03-taos-sql/10-function.md
+++ b/docs/en/14-reference/03-taos-sql/10-function.md
@@ -943,6 +943,7 @@ CHAR(expr1 [, expr2] [, expr3] ...)
 - NULL values in input parameters will be skipped.
 - If the input parameters are of string type, they will be converted to numeric type for processing.
 - If the character corresponding to the input parameter is a non-printable character, the return value will still contain the character corresponding to that parameter, but it may not be displayed.
+- This function can have at most 2^31 - 1 input parameters.
 
 **Examples**:
 
diff --git a/docs/zh/14-reference/03-taos-sql/10-function.md b/docs/zh/14-reference/03-taos-sql/10-function.md
index c075545ff3..eb3a4bb0ed 100644
--- a/docs/zh/14-reference/03-taos-sql/10-function.md
+++ b/docs/zh/14-reference/03-taos-sql/10-function.md
@@ -902,6 +902,7 @@ CHAR(expr1 [, expr2] [, epxr3] ...)
 - 输入参数的 NULL 值会被跳过。
 - 输入参数若为字符串类型，会将其转换为数值类型处理。
 - 若输入的参数对应的字符为不可打印字符，返回值中仍有该参数对应的字符，但是可能无法显示出来。
+- 输入参数的个数上限为 2^31 - 1 个。
 
 **举例**：
 ```sql
diff --git a/source/libs/function/src/builtins.c b/source/libs/function/src/builtins.c
index 95a332ac05..b42d739b40 100644
--- a/source/libs/function/src/builtins.c
+++ b/source/libs/function/src/builtins.c
@@ -828,14 +828,20 @@ static int32_t validateParam(SFunctionNode* pFunc, char* pErrBuf, int32_t len) {
     const SParamInfo* paramPattern = funcMgtBuiltins[pFunc->funcId].parameters.inputParaInfo[i];
 
     while (1) {
-      for (int8_t j = paramPattern[paramIdx].startParam;
-           j <= (paramPattern[paramIdx].endParam == -1 ? INT8_MAX : paramPattern[paramIdx].endParam); j++) {
+      // one table can have at most 4096 columns, int32_t is enough.
+      for (int32_t j = paramPattern[paramIdx].startParam;
+           j <= (paramPattern[paramIdx].endParam == -1 ? INT32_MAX - 1 : paramPattern[paramIdx].endParam); j++) {
         if (j > LIST_LENGTH(paramList)) {
           code = TSDB_CODE_SUCCESS;
           isMatch = true;
           break;
         }
         SNode* pNode = nodesListGetNode(paramList, j - 1);
+        if (NULL == pNode) {
+          code = TSDB_CODE_FUNC_FUNTION_PARA_NUM;
+          isMatch = false;
+          break;
+        }
         // check node type
         if (!paramSupportNodeType(pNode, paramPattern[paramIdx].validNodeType)) {
           code = TSDB_CODE_FUNC_FUNTION_PARA_TYPE;
diff --git a/tests/army/query/function/test_func_paramnum.py b/tests/army/query/function/test_func_paramnum.py
new file mode 100644
index 0000000000..37930cd624
--- /dev/null
+++ b/tests/army/query/function/test_func_paramnum.py
@@ -0,0 +1,42 @@
+###################################################################
+#           Copyright (c) 2016 by TAOS Technologies, Inc.
+#                     All rights reserved.
+#
+#  This file is proprietary and confidential to TAOS Technologies.
+#  No part of this file may be reproduced, stored, transmitted,
+#  disclosed or used in any form or by any means other than as
+#  expressly provided by the written permission from Jianhui Tao
+#
+###################################################################
+
+# -*- coding: utf-8 -*-
+
+from frame import etool
+from frame.etool import *
+from frame.log import *
+from frame.cases import *
+from frame.sql import *
+from frame.caseBase import *
+from frame.common import *
+
+class TDTestCase(TBase):
+    def create_table(self):
+        etool.benchMark(command = "-l 1000 -n 1 -d ts_5798")
+
+    def run(self):
+        tdLog.debug(f"start to excute {__file__}")
+
+        self.create_table()
+
+        tdSql.query("select last_row(c1, c2, c3, c4, c5, c6, c7, c8, c9, c10, c11, c12, c13, c14, c15, c16, c17, c18, c19, c20, c21, c22, c23, c24, c25, c26, c27, c28, c29, c30, c31, c32, c33, c34, c35, c36, c37, c38, c39, c40, c41, c42, c43, c44, c45, c46, c47, c48, c49, c50, c51, c52, c53, c54, c55, c56, c57, c58, c59, c60, c61, c62, c63, c64, c65, c66, c67, c68, c69, c70, c71, c72, c73, c74, c75, c76, c77, c78, c79, c80, c81, c82, c83, c84, c85, c86, c87, c88, c89, c90, c91, c92, c93, c94, c95, c96, c97, c98, c99, c100, c101, c102, c103, c104, c105, c106, c107, c108, c109, c110, c111, c112, c113, c114, c115, c116, c117, c118, c119, c120, c121, c122, c123, c124, c125, c126, c127, c128, c129, c130, c131, c132, c133, c134, c135, c136, c137, c138, c139, c140, c141, c142, c143, c144, c145, c146, c147, c148, c149, c150, c151, c152, c153, c154, c155, c156, c157, c158, c159, c160, c161, c162, c163, c164, c165, c166, c167, c168, c169, c170, c171, c172, c173, c174, c175, c176, c177, c178, c179, c180, c181, c182, c183, c184, c185, c186, c187, c188, c189, c190, c191, c192, c193, c194, c195, c196, c197, c198, c199, c200, c201, c202, c203, c204, c205, c206, c207, c208, c209, c210, c211, c212, c213, c214, c215, c216, c217, c218, c219, c220, c221, c222, c223, c224, c225, c226, c227, c228, c229, c230, c231, c232, c233, c234, c235, c236, c237, c238, c239, c240, c241, c242, c243, c244, c245, c246, c247, c248, c249, c250, c251, c252, c253, c254, c255, c256, c257, c258, c259, c260, c261, c262, c263, c264, c265, c266, c267, c268, c269, c270, c271, c272, c273, c274, c275, c276, c277, c278, c279, c280, c281, c282, c283, c284, c285, c286, c287, c288, c289, c290, c291, c292, c293, c294, c295, c296, c297, c298, c299, c300, c301, c302, c303, c304, c305, c306, c307, c308, c309, c310, c311, c312, c313, c314, c315, c316, c317, c318, c319, c320, c321, c322, c323, c324, c325, c326, c327, c328, c329, c330, c331, c332, c333, c334, c335, c336, c337, c338, c339, c340, c341, c342, c343, c344, c345, c346, c347, c348, c349, c350, c351, c352, c353, c354, c355, c356, c357, c358, c359, c360, c361, c362, c363, c364, c365, c366, c367, c368, c369, c370, c371, c372, c373, c374, c375, c376, c377, c378, c379, c380, c381, c382, c383, c384, c385, c386, c387, c388, c389, c390, c391, c392, c393, c394, c395, c396, c397, c398, c399, c400, c401, c402, c403, c404, c405, c406, c407, c408, c409, c410, c411, c412, c413, c414, c415, c416, c417, c418, c419, c420, c421, c422, c423, c424, c425, c426, c427, c428, c429, c430, c431, c432, c433, c434, c435, c436, c437, c438, c439, c440, c441, c442, c443, c444, c445, c446, c447, c448, c449, c450, c451, c452, c453, c454, c455, c456, c457, c458, c459, c460, c461, c462, c463, c464, c465, c466, c467, c468, c469, c470, c471, c472, c473, c474, c475, c476, c477, c478, c479, c480, c481, c482, c483, c484, c485, c486, c487, c488, c489, c490, c491, c492, c493, c494, c495, c496, c497, c498, c499, c500, c501, c502, c503, c504, c505, c506, c507, c508, c509, c510, c511, c512, c513, c514, c515, c516, c517, c518, c519, c520)  from ts_5798.meters;")
+        tdSql.checkRows(1)
+        tdSql.query("select first(c1, c2, c3, c4, c5, c6, c7, c8, c9, c10, c11, c12, c13, c14, c15, c16, c17, c18, c19, c20, c21, c22, c23, c24, c25, c26, c27, c28, c29, c30, c31, c32, c33, c34, c35, c36, c37, c38, c39, c40, c41, c42, c43, c44, c45, c46, c47, c48, c49, c50, c51, c52, c53, c54, c55, c56, c57, c58, c59, c60, c61, c62, c63, c64, c65, c66, c67, c68, c69, c70, c71, c72, c73, c74, c75, c76, c77, c78, c79, c80, c81, c82, c83, c84, c85, c86, c87, c88, c89, c90, c91, c92, c93, c94, c95, c96, c97, c98, c99, c100, c101, c102, c103, c104, c105, c106, c107, c108, c109, c110, c111, c112, c113, c114, c115, c116, c117, c118, c119, c120, c121, c122, c123, c124, c125, c126, c127, c128, c129, c130, c131, c132, c133, c134, c135, c136, c137, c138, c139, c140, c141, c142, c143, c144, c145, c146, c147, c148, c149, c150, c151, c152, c153, c154, c155, c156, c157, c158, c159, c160, c161, c162, c163, c164, c165, c166, c167, c168, c169, c170, c171, c172, c173, c174, c175, c176, c177, c178, c179, c180, c181, c182, c183, c184, c185, c186, c187, c188, c189, c190, c191, c192, c193, c194, c195, c196, c197, c198, c199, c200, c201, c202, c203, c204, c205, c206, c207, c208, c209, c210, c211, c212, c213, c214, c215, c216, c217, c218, c219, c220, c221, c222, c223, c224, c225, c226, c227, c228, c229, c230, c231, c232, c233, c234, c235, c236, c237, c238, c239, c240, c241, c242, c243, c244, c245, c246, c247, c248, c249, c250, c251, c252, c253, c254, c255, c256, c257, c258, c259, c260, c261, c262, c263, c264, c265, c266, c267, c268, c269, c270, c271, c272, c273, c274, c275, c276, c277, c278, c279, c280, c281, c282, c283, c284, c285, c286, c287, c288, c289, c290, c291, c292, c293, c294, c295, c296, c297, c298, c299, c300, c301, c302, c303, c304, c305, c306, c307, c308, c309, c310, c311, c312, c313, c314, c315, c316, c317, c318, c319, c320, c321, c322, c323, c324, c325, c326, c327, c328, c329, c330, c331, c332, c333, c334, c335, c336, c337, c338, c339, c340, c341, c342, c343, c344, c345, c346, c347, c348, c349, c350, c351, c352, c353, c354, c355, c356, c357, c358, c359, c360, c361, c362, c363, c364, c365, c366, c367, c368, c369, c370, c371, c372, c373, c374, c375, c376, c377, c378, c379, c380, c381, c382, c383, c384, c385, c386, c387, c388, c389, c390, c391, c392, c393, c394, c395, c396, c397, c398, c399, c400, c401, c402, c403, c404, c405, c406, c407, c408, c409, c410, c411, c412, c413, c414, c415, c416, c417, c418, c419, c420, c421, c422, c423, c424, c425, c426, c427, c428, c429, c430, c431, c432, c433, c434, c435, c436, c437, c438, c439, c440, c441, c442, c443, c444, c445, c446, c447, c448, c449, c450, c451, c452, c453, c454, c455, c456, c457, c458, c459, c460, c461, c462, c463, c464, c465, c466, c467, c468, c469, c470, c471, c472, c473, c474, c475, c476, c477, c478, c479, c480, c481, c482, c483, c484, c485, c486, c487, c488, c489, c490, c491, c492, c493, c494, c495, c496, c497, c498, c499, c500, c501, c502, c503, c504, c505, c506, c507, c508, c509, c510, c511, c512, c513, c514, c515, c516, c517, c518, c519, c520)  from ts_5798.meters;")
+        tdSql.checkRows(1)
+        tdSql.query("select last(c1, c2, c3, c4, c5, c6, c7, c8, c9, c10, c11, c12, c13, c14, c15, c16, c17, c18, c19, c20, c21, c22, c23, c24, c25, c26, c27, c28, c29, c30, c31, c32, c33, c34, c35, c36, c37, c38, c39, c40, c41, c42, c43, c44, c45, c46, c47, c48, c49, c50, c51, c52, c53, c54, c55, c56, c57, c58, c59, c60, c61, c62, c63, c64, c65, c66, c67, c68, c69, c70, c71, c72, c73, c74, c75, c76, c77, c78, c79, c80, c81, c82, c83, c84, c85, c86, c87, c88, c89, c90, c91, c92, c93, c94, c95, c96, c97, c98, c99, c100, c101, c102, c103, c104, c105, c106, c107, c108, c109, c110, c111, c112, c113, c114, c115, c116, c117, c118, c119, c120, c121, c122, c123, c124, c125, c126, c127, c128, c129, c130, c131, c132, c133, c134, c135, c136, c137, c138, c139, c140, c141, c142, c143, c144, c145, c146, c147, c148, c149, c150, c151, c152, c153, c154, c155, c156, c157, c158, c159, c160, c161, c162, c163, c164, c165, c166, c167, c168, c169, c170, c171, c172, c173, c174, c175, c176, c177, c178, c179, c180, c181, c182, c183, c184, c185, c186, c187, c188, c189, c190, c191, c192, c193, c194, c195, c196, c197, c198, c199, c200, c201, c202, c203, c204, c205, c206, c207, c208, c209, c210, c211, c212, c213, c214, c215, c216, c217, c218, c219, c220, c221, c222, c223, c224, c225, c226, c227, c228, c229, c230, c231, c232, c233, c234, c235, c236, c237, c238, c239, c240, c241, c242, c243, c244, c245, c246, c247, c248, c249, c250, c251, c252, c253, c254, c255, c256, c257, c258, c259, c260, c261, c262, c263, c264, c265, c266, c267, c268, c269, c270, c271, c272, c273, c274, c275, c276, c277, c278, c279, c280, c281, c282, c283, c284, c285, c286, c287, c288, c289, c290, c291, c292, c293, c294, c295, c296, c297, c298, c299, c300, c301, c302, c303, c304, c305, c306, c307, c308, c309, c310, c311, c312, c313, c314, c315, c316, c317, c318, c319, c320, c321, c322, c323, c324, c325, c326, c327, c328, c329, c330, c331, c332, c333, c334, c335, c336, c337, c338, c339, c340, c341, c342, c343, c344, c345, c346, c347, c348, c349, c350, c351, c352, c353, c354, c355, c356, c357, c358, c359, c360, c361, c362, c363, c364, c365, c366, c367, c368, c369, c370, c371, c372, c373, c374, c375, c376, c377, c378, c379, c380, c381, c382, c383, c384, c385, c386, c387, c388, c389, c390, c391, c392, c393, c394, c395, c396, c397, c398, c399, c400, c401, c402, c403, c404, c405, c406, c407, c408, c409, c410, c411, c412, c413, c414, c415, c416, c417, c418, c419, c420, c421, c422, c423, c424, c425, c426, c427, c428, c429, c430, c431, c432, c433, c434, c435, c436, c437, c438, c439, c440, c441, c442, c443, c444, c445, c446, c447, c448, c449, c450, c451, c452, c453, c454, c455, c456, c457, c458, c459, c460, c461, c462, c463, c464, c465, c466, c467, c468, c469, c470, c471, c472, c473, c474, c475, c476, c477, c478, c479, c480, c481, c482, c483, c484, c485, c486, c487, c488, c489, c490, c491, c492, c493, c494, c495, c496, c497, c498, c499, c500, c501, c502, c503, c504, c505, c506, c507, c508, c509, c510, c511, c512, c513, c514, c515, c516, c517, c518, c519, c520)  from ts_5798.meters;")
+        tdSql.checkRows(1)
+
+    tdLog.success(f"{__file__} successfully executed")
+
+
+tdCases.addLinux(__file__, TDTestCase())
+tdCases.addWindows(__file__, TDTestCase())
diff --git a/tests/parallel_test/cases.task b/tests/parallel_test/cases.task
index c9d28e0623..0377ff1641 100644
--- a/tests/parallel_test/cases.task
+++ b/tests/parallel_test/cases.task
@@ -16,6 +16,7 @@
 ,,y,army,./pytest.sh python3 ./test.py -f query/function/test_func_elapsed.py
 ,,y,army,./pytest.sh python3 ./test.py -f query/function/test_function.py
 ,,y,army,./pytest.sh python3 ./test.py -f query/function/test_selection_function_with_json.py
+,,y,army,./pytest.sh python3 ./test.py -f query/function/test_func_paramnum.py
 ,,y,army,./pytest.sh python3 ./test.py -f query/function/test_percentile.py
 ,,y,army,./pytest.sh python3 ./test.py -f query/function/test_resinfo.py
 ,,y,army,./pytest.sh python3 ./test.py -f query/function/test_interp.py

From 221d1553836517f3e61a18adc96a433bcdb24797 Mon Sep 17 00:00:00 2001
From: haoranchen <haoran920c@163.com>
Date: Mon, 23 Dec 2024 19:17:56 +0800
Subject: [PATCH 06/13] enh: ignore some tanalytics files in Jenkinsfile2

---
 Jenkinsfile2 | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/Jenkinsfile2 b/Jenkinsfile2
index 6fa3483099..7987164ec0 100644
--- a/Jenkinsfile2
+++ b/Jenkinsfile2
@@ -7,6 +7,8 @@ file_zh_changed = ''
 file_en_changed = ''
 file_no_doc_changed = '1'
 file_only_tdgpt_change_except = '1'
+tdgpt_file = "forecastoperator.c\\|anomalywindowoperator.c\\|tanalytics.h\\|tanalytics.c\\|tdgpt_cases.task"
+
 def abortPreviousBuilds() {
     def currentJobName = env.JOB_NAME
     def currentBuildNumber = env.BUILD_NUMBER.toInteger()
@@ -78,7 +80,7 @@ def check_docs(){
         file_only_tdgpt_change_except = sh (
             script: '''
                 cd ${WKC}
-                git --no-pager diff --name-only FETCH_HEAD `git merge-base FETCH_HEAD ${CHANGE_TARGET}`|grep -v "^docs/en/"|grep -v "^docs/zh/"|grep -v ".md$" | grep -v  "forecastoperator.c\\|anomalywindowoperator.c\\|tanalytics.h\\|tanalytics.c" |grep -v "tsim/analytics" |grep -v "tdgpt_cases.task" || :
+                git --no-pager diff --name-only FETCH_HEAD `git merge-base FETCH_HEAD ${CHANGE_TARGET}`|grep -v "^docs/en/"|grep -v "^docs/zh/"|grep -v ".md$" | grep -v ${tdgpt_file}  |grep -v "tsim/analytics" |grep -v "tdgpt_cases.task" || :
             ''',
             returnStdout: true
         ).trim()
@@ -570,7 +572,7 @@ pipeline {
                                        cd ${WKC}/tests/parallel_test
                                        ./run_scan_container.sh -d ${WKDIR} -b ${BRANCH_NAME}_${BUILD_ID}  -f ${WKDIR}/tmp/${BRANCH_NAME}_${BUILD_ID}/docs_changed.txt ''' + extra_param + '''
                                     '''
-                                    if ( file_no_doc_changed =~ /forecastoperator.c|anomalywindowoperator.c|tsim\/analytics|tdgpt_cases.task/ ) {
+                                    if ( file_no_doc_changed =~ ${tdgpt_file} ) {
                                         sh '''
                                             cd ${WKC}/tests/parallel_test
                                             export DEFAULT_RETRY_TIME=2

From b0b0c30d393165e41bf84bf2c23955edbc1fb46a Mon Sep 17 00:00:00 2001
From: haoranchen <haoran920c@163.com>
Date: Mon, 23 Dec 2024 20:20:57 +0800
Subject: [PATCH 07/13] Update Jenkinsfile2

---
 Jenkinsfile2 | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/Jenkinsfile2 b/Jenkinsfile2
index 7987164ec0..8d6851e19c 100644
--- a/Jenkinsfile2
+++ b/Jenkinsfile2
@@ -572,7 +572,7 @@ pipeline {
                                        cd ${WKC}/tests/parallel_test
                                        ./run_scan_container.sh -d ${WKDIR} -b ${BRANCH_NAME}_${BUILD_ID}  -f ${WKDIR}/tmp/${BRANCH_NAME}_${BUILD_ID}/docs_changed.txt ''' + extra_param + '''
                                     '''
-                                    if ( file_no_doc_changed =~ ${tdgpt_file} ) {
+                                    if ( file_no_doc_changed =~ /forecastoperator.c|anomalywindowoperator.c|tsim\/analytics|tdgpt_cases.task｜tanalytics/ ) {
                                         sh '''
                                             cd ${WKC}/tests/parallel_test
                                             export DEFAULT_RETRY_TIME=2

From 1d4eb3b5b9745aa98f178dd6f641083b75e4169a Mon Sep 17 00:00:00 2001
From: haoranchen <haoran920c@163.com>
Date: Mon, 23 Dec 2024 20:40:44 +0800
Subject: [PATCH 08/13] Update Jenkinsfile2

---
 Jenkinsfile2 | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/Jenkinsfile2 b/Jenkinsfile2
index 8d6851e19c..2763076c5f 100644
--- a/Jenkinsfile2
+++ b/Jenkinsfile2
@@ -572,7 +572,7 @@ pipeline {
                                        cd ${WKC}/tests/parallel_test
                                        ./run_scan_container.sh -d ${WKDIR} -b ${BRANCH_NAME}_${BUILD_ID}  -f ${WKDIR}/tmp/${BRANCH_NAME}_${BUILD_ID}/docs_changed.txt ''' + extra_param + '''
                                     '''
-                                    if ( file_no_doc_changed =~ /forecastoperator.c|anomalywindowoperator.c|tsim\/analytics|tdgpt_cases.task｜tanalytics/ ) {
+                                    if ( file_no_doc_changed =~ /forecastoperator.c|anomalywindowoperator.c|tsim\/analytics|tdgpt_cases.task|tanalytics/ ) {
                                         sh '''
                                             cd ${WKC}/tests/parallel_test
                                             export DEFAULT_RETRY_TIME=2

From bc10b0683a4e624c678cd579036ed850a5a6acfe Mon Sep 17 00:00:00 2001
From: haoranchen <haoran920c@163.com>
Date: Mon, 23 Dec 2024 21:10:59 +0800
Subject: [PATCH 09/13] enh: set  file strings  as args  in Jenkinsfile2

---
 Jenkinsfile2 | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/Jenkinsfile2 b/Jenkinsfile2
index 2763076c5f..df0892cfa1 100644
--- a/Jenkinsfile2
+++ b/Jenkinsfile2
@@ -7,7 +7,7 @@ file_zh_changed = ''
 file_en_changed = ''
 file_no_doc_changed = '1'
 file_only_tdgpt_change_except = '1'
-tdgpt_file = "forecastoperator.c\\|anomalywindowoperator.c\\|tanalytics.h\\|tanalytics.c\\|tdgpt_cases.task"
+tdgpt_file = "forecastoperator.c\\|anomalywindowoperator.c\\|tanalytics.h\\|tanalytics.c\\|tdgpt_cases.task\\|analytics"
 
 def abortPreviousBuilds() {
     def currentJobName = env.JOB_NAME
@@ -80,7 +80,7 @@ def check_docs(){
         file_only_tdgpt_change_except = sh (
             script: '''
                 cd ${WKC}
-                git --no-pager diff --name-only FETCH_HEAD `git merge-base FETCH_HEAD ${CHANGE_TARGET}`|grep -v "^docs/en/"|grep -v "^docs/zh/"|grep -v ".md$" | grep -v ${tdgpt_file}  |grep -v "tsim/analytics" |grep -v "tdgpt_cases.task" || :
+                git --no-pager diff --name-only FETCH_HEAD `git merge-base FETCH_HEAD ${CHANGE_TARGET}`|grep -v "^docs/en/"|grep -v "^docs/zh/"|grep -v ".md$" | grep -v ${tdgpt_file} " || :
             ''',
             returnStdout: true
         ).trim()
@@ -572,7 +572,7 @@ pipeline {
                                        cd ${WKC}/tests/parallel_test
                                        ./run_scan_container.sh -d ${WKDIR} -b ${BRANCH_NAME}_${BUILD_ID}  -f ${WKDIR}/tmp/${BRANCH_NAME}_${BUILD_ID}/docs_changed.txt ''' + extra_param + '''
                                     '''
-                                    if ( file_no_doc_changed =~ /forecastoperator.c|anomalywindowoperator.c|tsim\/analytics|tdgpt_cases.task|tanalytics/ ) {
+                                    if ( file_no_doc_changed =~ /${tdgpt_file}/ ) {
                                         sh '''
                                             cd ${WKC}/tests/parallel_test
                                             export DEFAULT_RETRY_TIME=2

From f05dc19cff83cd28c1a1de3c94c769f7de513d87 Mon Sep 17 00:00:00 2001
From: haoranchen <haoran920c@163.com>
Date: Mon, 23 Dec 2024 21:14:14 +0800
Subject: [PATCH 10/13] enh: set file strings as args in Jenkinsfile2

---
 Jenkinsfile2 | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/Jenkinsfile2 b/Jenkinsfile2
index df0892cfa1..dd148dc447 100644
--- a/Jenkinsfile2
+++ b/Jenkinsfile2
@@ -80,7 +80,7 @@ def check_docs(){
         file_only_tdgpt_change_except = sh (
             script: '''
                 cd ${WKC}
-                git --no-pager diff --name-only FETCH_HEAD `git merge-base FETCH_HEAD ${CHANGE_TARGET}`|grep -v "^docs/en/"|grep -v "^docs/zh/"|grep -v ".md$" | grep -v ${tdgpt_file} " || :
+                git --no-pager diff --name-only FETCH_HEAD `git merge-base FETCH_HEAD ${CHANGE_TARGET}`|grep -v "^docs/en/"|grep -v "^docs/zh/"|grep -v ".md$" | grep -v ${tdgpt_file} || :
             ''',
             returnStdout: true
         ).trim()

From 493a23a4803da53ca7ae5ab61b47ac135ca247eb Mon Sep 17 00:00:00 2001
From: Haolin Wang <haolinwang@taosdata.com>
Date: Tue, 24 Dec 2024 08:09:35 +0800
Subject: [PATCH 11/13] fix: free unallocated memory in tsdbRowClose()

---
 source/dnode/vnode/src/tsdb/tsdbCache.c | 6 ++----
 source/dnode/vnode/src/tsdb/tsdbUtil.c  | 4 +++-
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/source/dnode/vnode/src/tsdb/tsdbCache.c b/source/dnode/vnode/src/tsdb/tsdbCache.c
index 2047b68101..5151ea3958 100644
--- a/source/dnode/vnode/src/tsdb/tsdbCache.c
+++ b/source/dnode/vnode/src/tsdb/tsdbCache.c
@@ -610,6 +610,7 @@ int32_t tsdbLoadFromImem(SMemTable *imem, int64_t suid, int64_t uid) {
   int32_t     nCol;
   SArray     *ctxArray = pTsdb->rCache.ctxArray;
   STsdbRowKey tsdbRowKey = {0};
+  STSDBRowIter iter = {0};
 
   STbData *pIMem = tsdbGetTbDataFromMemTable(imem, suid, uid);
 
@@ -641,7 +642,6 @@ int32_t tsdbLoadFromImem(SMemTable *imem, int64_t suid, int64_t uid) {
 
   tsdbRowGetKey(pMemRow, &tsdbRowKey);
 
-  STSDBRowIter iter = {0};
   TAOS_CHECK_EXIT(tsdbRowIterOpen(&iter, pMemRow, pTSchema));
 
   int32_t iCol = 0;
@@ -685,7 +685,6 @@ int32_t tsdbLoadFromImem(SMemTable *imem, int64_t suid, int64_t uid) {
     STsdbRowKey tsdbRowKey = {0};
     tsdbRowGetKey(pMemRow, &tsdbRowKey);
 
-    STSDBRowIter iter = {0};
     TAOS_CHECK_EXIT(tsdbRowIterOpen(&iter, pMemRow, pTSchema));
 
     int32_t iCol = 0;
@@ -2470,6 +2469,7 @@ static int32_t tsdbCacheGetBatchFromMem(STsdb *pTsdb, tb_uid_t uid, SArray *pLas
   int            numKeys = TARRAY_SIZE(pCidList);
   MemNextRowIter iter = {0};
   SSHashObj     *iColHash = NULL;
+  STSDBRowIter   rowIter = {0};
 
   // 1, get from mem, imem filtered with delete info
   TAOS_CHECK_EXIT(memRowIterOpen(&iter, uid, pTsdb, pTSchema, pr->info.suid, pr->pReadSnap, pr));
@@ -2490,7 +2490,6 @@ static int32_t tsdbCacheGetBatchFromMem(STsdb *pTsdb, tb_uid_t uid, SArray *pLas
   STsdbRowKey rowKey = {0};
   tsdbRowGetKey(pRow, &rowKey);
 
-  STSDBRowIter rowIter = {0};
   TAOS_CHECK_EXIT(tsdbRowIterOpen(&rowIter, pRow, pTSchema));
 
   int32_t iCol = 0, jCol = 0, jnCol = TARRAY_SIZE(pLastArray);
@@ -2564,7 +2563,6 @@ static int32_t tsdbCacheGetBatchFromMem(STsdb *pTsdb, tb_uid_t uid, SArray *pLas
       STsdbRowKey tsdbRowKey = {0};
       tsdbRowGetKey(pRow, &tsdbRowKey);
 
-      STSDBRowIter rowIter = {0};
       TAOS_CHECK_EXIT(tsdbRowIterOpen(&rowIter, pRow, pTSchema));
 
       iCol = 0;
diff --git a/source/dnode/vnode/src/tsdb/tsdbUtil.c b/source/dnode/vnode/src/tsdb/tsdbUtil.c
index f807ecf2d6..16f6777765 100644
--- a/source/dnode/vnode/src/tsdb/tsdbUtil.c
+++ b/source/dnode/vnode/src/tsdb/tsdbUtil.c
@@ -699,9 +699,11 @@ int32_t tsdbRowIterOpen(STSDBRowIter *pIter, TSDBROW *pRow, STSchema *pTSchema)
 }
 
 void tsdbRowClose(STSDBRowIter *pIter) {
-  if (pIter->pRow->type == TSDBROW_ROW_FMT) {
+  if (pIter->pRow && pIter->pRow->type == TSDBROW_ROW_FMT) {
     tRowIterClose(&pIter->pIter);
   }
+  pIter->pRow = NULL;
+  pIter->pIter = NULL;
 }
 
 SColVal *tsdbRowIterNext(STSDBRowIter *pIter) {

From d3d48d93aa37e8f5484b586afe4d891435db916b Mon Sep 17 00:00:00 2001
From: haoranchen <haoran920c@163.com>
Date: Tue, 24 Dec 2024 09:18:28 +0800
Subject: [PATCH 12/13] revert  Jenkinsfile2

---
 Jenkinsfile2 | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/Jenkinsfile2 b/Jenkinsfile2
index dd148dc447..fc00c5e2dc 100644
--- a/Jenkinsfile2
+++ b/Jenkinsfile2
@@ -572,7 +572,7 @@ pipeline {
                                        cd ${WKC}/tests/parallel_test
                                        ./run_scan_container.sh -d ${WKDIR} -b ${BRANCH_NAME}_${BUILD_ID}  -f ${WKDIR}/tmp/${BRANCH_NAME}_${BUILD_ID}/docs_changed.txt ''' + extra_param + '''
                                     '''
-                                    if ( file_no_doc_changed =~ /${tdgpt_file}/ ) {
+                                    if ( file_no_doc_changed =~ /orecastoperator.c|anomalywindowoperator.c|tanalytics.h|tanalytics.c|tdgpt_cases.task|analytics/ ) {
                                         sh '''
                                             cd ${WKC}/tests/parallel_test
                                             export DEFAULT_RETRY_TIME=2

From f9976c75ef4cbf3e5ed8fcb136646d56d6abe1de Mon Sep 17 00:00:00 2001
From: wangmm0220 <wangmm0220@gmail.com>
Date: Tue, 24 Dec 2024 09:54:05 +0800
Subject: [PATCH 13/13] fix:error rewrite if terrno is not 0

---
 source/dnode/vnode/src/vnd/vnodeSync.c | 1 -
 1 file changed, 1 deletion(-)

diff --git a/source/dnode/vnode/src/vnd/vnodeSync.c b/source/dnode/vnode/src/vnd/vnodeSync.c
index 50bedba75d..cea82c13ff 100644
--- a/source/dnode/vnode/src/vnd/vnodeSync.c
+++ b/source/dnode/vnode/src/vnd/vnodeSync.c
@@ -313,7 +313,6 @@ void vnodeProposeWriteMsg(SQueueInfo *pInfo, STaosQall *qall, int32_t numOfMsgs)
     if (code != 0) {
       if (code != TSDB_CODE_MSG_PREPROCESSED) {
         vGError("vgId:%d, msg:%p failed to pre-process since %s", vgId, pMsg, tstrerror(code));
-        if (terrno != 0) code = terrno;
       }
       vnodeHandleProposeError(pVnode, pMsg, code);
       rpcFreeCont(pMsg->pCont);