diff --git a/src/client/src/tscSQLParser.c b/src/client/src/tscSQLParser.c
index 3032b27b9cab6005d9cde120ede7fde831df181f..0c8664b692bd01c9637cd7e8817f0a2d3796b2ca 100644
--- a/src/client/src/tscSQLParser.c
+++ b/src/client/src/tscSQLParser.c
@@ -9596,7 +9596,11 @@ static STableMeta* extractTempTableMetaFromSubquery(SQueryInfo* pUpstream) {
     meta->schema[n].type  = pField->field.type;
 
     SExprInfo* pExpr = pField->pExpr;
-    meta->schema[n].colId = pExpr->base.resColId;
+    if (pExpr->base.colInfo.colId == PRIMARYKEY_TIMESTAMP_COL_INDEX) {
+      meta->schema[n].colId = PRIMARYKEY_TIMESTAMP_COL_INDEX;
+    } else {
+      meta->schema[n].colId = pExpr->base.resColId;
+    }
     tstrncpy(meta->schema[n].name, pField->pExpr->base.aliasName, TSDB_COL_NAME_LEN);
     info->rowSize += meta->schema[n].bytes;