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

yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/branch-2.1 by this push:
     new 17811f7d298 branch-2.1: [regression-test](case) fix manager case bug 
#46659 (#46669)
17811f7d298 is described below

commit 17811f7d298595938e33522a505e918e954d2a08
Author: github-actions[bot] 
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Jan 9 22:19:17 2025 +0800

    branch-2.1: [regression-test](case) fix manager case bug #46659 (#46669)
    
    Cherry-picked from #46659
    
    Co-authored-by: shuke <[email protected]>
---
 .../suites/manager/test_manager_interface_1.groovy | 24 +++++++++++-----------
 1 file changed, 12 insertions(+), 12 deletions(-)

diff --git a/regression-test/suites/manager/test_manager_interface_1.groovy 
b/regression-test/suites/manager/test_manager_interface_1.groovy
index 02186974ef9..856cb6802a9 100644
--- a/regression-test/suites/manager/test_manager_interface_1.groovy
+++ b/regression-test/suites/manager/test_manager_interface_1.groovy
@@ -504,7 +504,7 @@ suite('test_manager_interface_1',"p0") {
         futures.add( thread {
             sleep(1500)
 
-            result = sql """ 
+            result = sql_return_maparray """ 
             select a.*, b.*, c.NAME as WORKLOAD_GROUP_NAME from 
information_schema.active_queries a left join 
             information_schema.backend_active_tasks b on a.QUERY_ID = 
b.QUERY_ID left join information_schema.workload_groups c on 
a.WORKLOAD_GROUP_ID = c.ID
             """
@@ -513,21 +513,21 @@ suite('test_manager_interface_1',"p0") {
             def x = 0
             def queryId = ""
             for( int i =0 ;i < result.size();i++ ){
-                assertTrue(result[i][0] != null ) // QueryId
+                assertTrue(result[i]["QUERY_ID"] != null ) // QueryId
 
-                if ( result[i][9].contains("sleep(4.7676)")  ){
+                if ( result[i]["SQL"].contains("sleep(4.7676)")  ){
                     x = 1 
-                    queryId = result[i][0]
+                    queryId = result[i]["QUERY_ID"]
                     logger.info("result = ${queryId}}")
 
-                    assertTrue(result[i][2]!=null) // QUERY_TIME_MS  
-                    assertTrue(result[i][14]!=null) // TASK_CPU_TIME_MS   
-                    assertTrue(result[i][15].toBigInteger() ==0 ) // SCAN_ROWS 
 
-                    assertTrue(result[i][16].toBigInteger() ==0)//SCAN_BYTES
-                    assertTrue(result[i][19].toBigInteger() ==0) // 
SHUFFLE_SEND_BYTES     
-                    assertTrue(result[i][20].toBigInteger() ==0) // 
SHUFFLE_SEND_ROWS   
-                    assertTrue(result[i][18]!=null) // 
CURRENT_USED_MEMORY_BYTES   
-                    assertTrue(result[i][22]!=null) // WORKLOAD_GROUP_NAME     
         
+                    assertTrue(result[i]["QUERY_TIME_MS"]!=null) // 
QUERY_TIME_MS  
+                    assertTrue(result[i]["TASK_CPU_TIME_MS"]!=null) // 
TASK_CPU_TIME_MS   
+                    assertTrue(result[i]["SCAN_ROWS"].toBigInteger() ==0 ) // 
SCAN_ROWS  
+                    assertTrue(result[i]["SCAN_BYTES"].toBigInteger() 
==0)//SCAN_BYTES
+                    assertTrue(result[i]["SHUFFLE_SEND_BYTES"].toBigInteger() 
==0) // SHUFFLE_SEND_BYTES     
+                    assertTrue(result[i]["SHUFFLE_SEND_ROWS"].toBigInteger() 
==0) // SHUFFLE_SEND_ROWS   
+                    assertTrue(result[i]["CURRENT_USED_MEMORY_BYTES"]!=null) 
// CURRENT_USED_MEMORY_BYTES   
+                    assertTrue(result[i]["WORKLOAD_GROUP_ID"]!=null) // 
WORKLOAD_GROUP_NAME              
                 }
             }
             assertTrue(x == 1)


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to