From 11d34f728a8c9defe8c8aae42ff0a7ca998bd069 Mon Sep 17 00:00:00 2001
From: factosea <285808407@qq.com>
Date: Tue, 14 Jan 2025 17:04:07 +0800
Subject: [PATCH] fix: data load required

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

diff --git a/source/libs/function/src/builtinsimpl.c b/source/libs/function/src/builtinsimpl.c
index 707018ac65..0f6db39cc8 100644
--- a/source/libs/function/src/builtinsimpl.c
+++ b/source/libs/function/src/builtinsimpl.c
@@ -771,7 +771,34 @@ bool getSumFuncEnv(SFunctionNode* UNUSED_PARAM(pFunc), SFuncExecEnv* pEnv) {
   return true;
 }
 
+static bool funcNotSupportStringSma(SFunctionNode* pFunc) {
+  SNode* pParam;
+  switch (pFunc->funcType) {
+    case FUNCTION_TYPE_MAX:
+    case FUNCTION_TYPE_MIN:
+    case FUNCTION_TYPE_SUM:
+    case FUNCTION_TYPE_AVG:
+    case FUNCTION_TYPE_AVG_PARTIAL:
+    case FUNCTION_TYPE_PERCENTILE:
+    case FUNCTION_TYPE_SPREAD:
+    case FUNCTION_TYPE_SPREAD_PARTIAL:
+    case FUNCTION_TYPE_SPREAD_MERGE:
+    case FUNCTION_TYPE_TWA:
+      pParam = nodesListGetNode(pFunc->pParameterList, 0);
+      if (pParam && nodesIsExprNode(pParam) && (IS_VAR_DATA_TYPE(((SExprNode*)pParam)->resType.type))) {
+        return true;
+      }
+      break;
+    default:
+      break;
+  }
+  return false;
+}
+
 EFuncDataRequired statisDataRequired(SFunctionNode* pFunc, STimeWindow* pTimeWindow) {
+  if(funcNotSupportStringSma(pFunc)) {
+    return FUNC_DATA_REQUIRED_DATA_LOAD;
+  }
   return FUNC_DATA_REQUIRED_SMA_LOAD;
 }