fix(query): set the correct flag to denote the initialization status.

e91233f5 · Haojun Liao · 7429f37c · e91233f5
隐藏空白更改
内联并排

Showing with 6 addition and 2 deletion

source/libs/executor/src/executorimpl.c source/libs/executor/src/executorimpl.c +6 -2

未找到文件。
--- a/source/libs/executor/src/executorimpl.c
+++ b/source/libs/executor/src/executorimpl.c
@@ -2914,8 +2914,12 @@ void setResultRowOutputBufInitCtx_rv(SResultRow* pResult, SqlFunctionCtx* pCtx,
      continue;
    }

-    if (!pResInfo->initialized && pCtx[i].functionId != -1) {
-      pCtx[i].fpSet.init(&pCtx[i], pResInfo);
+    if (!pResInfo->initialized) {
+      if (pCtx[i].functionId != -1) {
+        pCtx[i].fpSet.init(&pCtx[i], pResInfo);
+      } else {
+        pResInfo->initialized = true;
+      }
    }
  }
 }