(iotdb) branch master updated: fix memory issue during testConcurrentCteQueries test (#17473)

[jackietien]

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new d06de8afc51 fix memory issue during testConcurrentCteQueries test 
(#17473)
d06de8afc51 is described below

commit d06de8afc510409babeff927eb574f30df84097f
Author: shizy <shiz...@gmail.com>
AuthorDate: Wed Apr 15 08:19:36 2026 +0800

    fix memory issue during testConcurrentCteQueries test (#17473)
---
 .../org/apache/iotdb/relational/it/query/recent/IoTDBCteIT.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBCteIT.java
 
b/integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBCteIT.java
index ceec77e78af..8c0b52acc94 100644
--- 
a/integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBCteIT.java
+++ 
b/integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBCteIT.java
@@ -498,7 +498,7 @@ public class IoTDBCteIT {
   @Test
   public void testConcurrentCteQueries() throws Exception {
     final int threadCount = 3;
-    final int queriesPerThread = 20;
+    final int queriesPerThread = 6;
     final AtomicInteger successCount = new AtomicInteger(0);
     final AtomicInteger failureCount = new AtomicInteger(0);
     final AtomicInteger totalCount = new AtomicInteger(0);
@@ -527,7 +527,7 @@ public class IoTDBCteIT {
                       // Test different types of CTE queries
                       String[] queries = {
                         String.format(
-                            "WITH cte as %s (select * from testtb WHERE 
voltage > 150) select * from cte ORDER BY deviceid",
+                            "WITH cte as %s (select * from testtb WHERE 
voltage > 150 order by deviceid) select * from cte",
                             cteKeywords[j % cteKeywords.length]),
                         String.format(
                             "WITH cte as %s (select deviceid, avg(voltage) as 
avg_v from testtb GROUP BY deviceid) select * from cte",
@@ -609,7 +609,7 @@ public class IoTDBCteIT {
     int totalQueries = threadCount * queriesPerThread;
     assertEquals("All queries should succeed", totalQueries, 
successCount.get());
     assertEquals("No queries should fail", 0, failureCount.get());
-    assertEquals("Total query count should match", 102, totalCount.get());
+    assertEquals("Total query count should match", 30, totalCount.get());
   }
 
   private static void prepareData() {