From 9a0f0d8829ea2e9cd7dec5c41cf62df622313ef4 Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao>
Date: Tue, 23 Jul 2024 19:31:43 +0800
Subject: [PATCH] fix udf ci error

---
 source/libs/executor/src/executil.c | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/source/libs/executor/src/executil.c b/source/libs/executor/src/executil.c
index 4d4dd3663f..5db27478fc 100644
--- a/source/libs/executor/src/executil.c
+++ b/source/libs/executor/src/executil.c
@@ -1080,6 +1080,7 @@ _end:
   if (code != TSDB_CODE_SUCCESS) {
     taosMemoryFree(pResBlock);
     qError("%s failed at line %d since %s", __func__, lino, tstrerror(code));
+    terrno = code;
     return NULL;
   }
   return pResBlock;
@@ -1857,8 +1858,8 @@ SqlFunctionCtx* createSqlFunctionCtx(SExprInfo* pExprInfo, int32_t numOfOutput,
       pCtx->isPseudoFunc = fmIsWindowPseudoColumnFunc(pCtx->functionId);
       pCtx->isNotNullFunc = fmIsNotNullOutputFunc(pCtx->functionId);
 
+      bool isUdaf = fmIsUserDefinedFunc(pCtx->functionId);
       if (fmIsAggFunc(pCtx->functionId) || fmIsIndefiniteRowsFunc(pCtx->functionId)) {
-        bool isUdaf = fmIsUserDefinedFunc(pCtx->functionId);
         if (!isUdaf) {
           code = fmGetFuncExecFuncs(pCtx->functionId, &pCtx->fpSet);
           QUERY_CHECK_CODE(code, lino, _end);
@@ -1875,6 +1876,9 @@ SqlFunctionCtx* createSqlFunctionCtx(SExprInfo* pExprInfo, int32_t numOfOutput,
         }
       } else {
         code = fmGetScalarFuncExecFuncs(pCtx->functionId, &pCtx->sfp);
+        if (code != TSDB_CODE_SUCCESS && isUdaf) {
+          code = TSDB_CODE_SUCCESS;
+        }
         QUERY_CHECK_CODE(code, lino, _end);
 
         if (pCtx->sfp.getEnv != NULL) {