diff --git a/src/client/src/tscSQLParser.c b/src/client/src/tscSQLParser.c index bf68543d3dc21e6b02a427b8baa005094ac94633..0fe0f73e9e32e84a19192fd5f009ddb015216c52 100644 --- a/src/client/src/tscSQLParser.c +++ b/src/client/src/tscSQLParser.c @@ -7574,6 +7574,10 @@ int32_t validateFunctionFromUpstream(SQueryInfo* pQueryInfo, char* msg) { if (!isSTable) { continue; } + + if (TSDB_QUERY_HAS_TYPE(pUp->type, TSDB_QUERY_TYPE_PROJECTION_QUERY)) { + return invalidOperationMsg(msg, msg5); + } for (int32_t n = 0; n < exprNum; ++n) { expr = taosArrayGetP(pUp->exprList, n);