diff --git a/src/client/src/tscSQLParser.c b/src/client/src/tscSQLParser.c
index b17f92809159990f3a44a7f8b45aeb042f911569..b53569c078fec12190ba681b18b184778ef494a3 100644
--- a/src/client/src/tscSQLParser.c
+++ b/src/client/src/tscSQLParser.c
@@ -9625,11 +9625,7 @@ static STableMeta* extractTempTableMetaFromSubquery(SQueryInfo* pUpstream) {
     meta->schema[n].type  = pField->field.type;
 
     SExprInfo* pExpr = pField->pExpr;
-    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;
-    }
+    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;