diff --git a/src/client/src/tscSQLParser.c b/src/client/src/tscSQLParser.c
index 0bdae50334bf3ede70edcc89fc4474f236c7a57e..b188ef1fe07c120ea1718b43a7d5063ba0b62247 100644
--- a/src/client/src/tscSQLParser.c
+++ b/src/client/src/tscSQLParser.c
@@ -1890,6 +1890,9 @@ static int32_t handleScalarTypeExpr(SSqlCmd* pCmd, SQueryInfo* pQueryInfo, int32
   SExprInfo* pExpr = tscExprAppend(pQueryInfo, TSDB_FUNC_SCALAR_EXPR, &idx, pNode->resultType, pNode->resultBytes,
                                    getNewResColId(pCmd), 0, false);
 
+  // set the colId to the result column id
+  pExpr->base.colInfo.colId = pExpr->base.resColId;
+
   char* name = (pItem->aliasName != NULL)? pItem->aliasName:pItem->pNode->exprToken.z;
   size_t len = MIN(sizeof(pExpr->base.aliasName), pItem->pNode->exprToken.n + 1);
   tstrncpy(pExpr->base.aliasName, name, len);