[TD-225]

36297455 · Haojun Liao · c8b2369a · 36297455
隐藏空白更改
内联并排

Showing with 4 addition and 3 deletion

src/client/src/tscServer.c src/client/src/tscServer.c +4 -3

未找到文件。
--- a/src/client/src/tscServer.c
+++ b/src/client/src/tscServer.c
@@ -787,9 +787,10 @@ int tscBuildQueryMsg(SSqlObj *pSql, SSqlInfo *pInfo) {
    pSqlFuncExpr = (SSqlFuncMsg *)pMsg;
  }

-  if (tscIsSecondStageQuery(pQueryInfo) || UTIL_TABLE_IS_NORMAL_TABLE(pTableMetaInfo) ||
-      UTIL_TABLE_IS_CHILD_TABLE(pTableMetaInfo)) {
-    size_t output = tscNumOfFields(pQueryInfo);
+  size_t output = tscNumOfFields(pQueryInfo);
+
+  if ((tscIsSecondStageQuery(pQueryInfo) || UTIL_TABLE_IS_NORMAL_TABLE(pTableMetaInfo) ||
+      UTIL_TABLE_IS_CHILD_TABLE(pTableMetaInfo)) && (output != tscSqlExprNumOfExprs(pQueryInfo))) {
    pQueryMsg->secondStageOutput = htonl((int32_t) output);

    SSqlFuncMsg *pSqlFuncExpr1 = (SSqlFuncMsg *)pMsg;