fix(stream): check udf

4cd1452e · 54liuyao · 51aa9413 · 4cd1452e
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

source/libs/executor/src/timewindowoperator.c source/libs/executor/src/timewindowoperator.c +1 -1

未找到文件。
--- a/source/libs/executor/src/timewindowoperator.c
+++ b/source/libs/executor/src/timewindowoperator.c
@@ -1695,7 +1695,7 @@ void destroyStreamFinalIntervalOperatorInfo(void* param, int32_t numOfOutput) {

 static bool allInvertible(SqlFunctionCtx* pFCtx, int32_t numOfCols) {
  for (int32_t i = 0; i < numOfCols; i++) {
-    if (!fmIsInvertible(pFCtx[i].functionId)) {
+    if (fmIsUserDefinedFunc(pFCtx[i].functionId) || !fmIsInvertible(pFCtx[i].functionId)) {
      return false;
    }
  }