Merge pull request #9650 from taosdata/fix/TS-802-V24

[TS-802]<fix>(query): add parent query have order by desc case

src/common/src/tglobal.c

@@ -289,7 +289,7 @@ char     Compressor[32] = "ZSTD_COMPRESSOR";  // ZSTD_COMPRESSOR or GZIP_COMPRES
 #endif
 
 // long query death-lock
-int8_t tsDeadLockKillQuery = 0;
+int8_t tsDeadLockKillQuery = 1;
 
 // default JSON string type
 char tsDefaultJSONStrType[7] = "nchar";

src/query/src/qExecutor.c

@@ -1808,11 +1808,17 @@ static bool functionNeedToExecute(SQueryRuntimeEnv *pRuntimeEnv, SQLFunctionCtx
   }
 
   if (functionId == TSDB_FUNC_FIRST_DST || functionId == TSDB_FUNC_FIRST) {
+    // if param[2] is set value, input data come from client, order is no relation with pQueryAttr->order , so always return true
+    if(pCtx->param[2].nType == TSDB_DATA_TYPE_INT)
+      return true;    
     return QUERY_IS_ASC_QUERY(pQueryAttr);
   }
 
   // denote the order type
   if ((functionId == TSDB_FUNC_LAST_DST || functionId == TSDB_FUNC_LAST)) {
+    // if param[2] is set value, input data come from client, order is no relation with pQueryAttr->order , so always return true
+    if(pCtx->param[2].nType == TSDB_DATA_TYPE_INT)
+      return true;    
     return pCtx->param[0].i64 == pQueryAttr->order.order;
   }
 

tests/pytest/query/queryBase.py

@@ -155,6 +155,21 @@ class TDTestCase:
         tdSql.waitedQuery(sql, 1, WAITS)
         tdSql.checkData(0, 1, 192419100)
 
+        # add parent query order by
+        # first 
+        sql = "select first(*) from (select first(i1) from st interval(10m) order by ts asc) order by ts desc;"
+        tdSql.waitedQuery(sql, 1, WAITS)
+        tdSql.checkData(0, 1, 0)
+        sql = "select first(*) from (select first(i1) from st interval(10m) order by ts desc) order by ts asc;"
+        tdSql.waitedQuery(sql, 1, WAITS)
+        tdSql.checkData(0, 1, 0)
+        # last
+        sql = "select last(*) from (select first(i1) from st interval(10m) order by ts asc) order by ts desc;"
+        tdSql.waitedQuery(sql, 1, WAITS)
+        tdSql.checkData(0, 1, 229400)
+        sql = "select last(*) from (select first(i1) from st interval(10m) order by ts desc) order by ts asc;"
+        tdSql.waitedQuery(sql, 1, WAITS)
+        tdSql.checkData(0, 1, 229400)
 
 #
 # add case with filename