diff --git a/regression-test/suites/manager/test_manager_interface_1.groovy b/regression-test/suites/manager/test_manager_interface_1.groovy
index 5248203d347b1d..1c9aa22620059e 100644
--- a/regression-test/suites/manager/test_manager_interface_1.groovy
+++ b/regression-test/suites/manager/test_manager_interface_1.groovy
@@ -471,7 +471,8 @@ suite('test_manager_interface_1',"p0") {
         futures.add( thread {
             
             try{
-                sql """ select sleep(4.7676); """
+                sql """ set parallel_pipeline_task_num= 1; """
+                sql """ select count(*) from numbers("number" = "598318892") as a join numbers("number" = "598318892") as b on a.number = b.number ; """
             }catch(Exception e){
             }
         })
@@ -491,19 +492,21 @@ suite('test_manager_interface_1',"p0") {
             for( int i =0 ;i < result.size();i++ ){
                 assertTrue(result[i]["QUERY_ID"] != null ) // QueryId
 
-                if ( result[i]["SQL"].contains("sleep(4.7676)")  ){
+                if ( result[i]["SQL"].contains("598318892")  ){
                     x = 1 
                     queryId = result[i]["QUERY_ID"]
                     logger.info("result = ${queryId}}")
 
                     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_NAME"]!=null) // WORKLOAD_GROUP_NAME              
+
+                    // unstable.
+                    // 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_NAME"]!=null) // WORKLOAD_GROUP_NAME              
                 }
             }
             assertTrue(x == 1)
diff --git a/regression-test/suites/manager/test_manager_interface_5.groovy b/regression-test/suites/manager/test_manager_interface_5.groovy
index 8c09cc49a822bd..5ae74b9d19681e 100644
--- a/regression-test/suites/manager/test_manager_interface_5.groovy
+++ b/regression-test/suites/manager/test_manager_interface_5.groovy
@@ -30,7 +30,8 @@ suite('test_manager_interface_5',"p0") {
         futures.add( thread {
             try{
                 sql """set session_context="trace_id:test_manager_interface_5_trace_id""""
-                sql """ select *  from numbers("number" = "9910") as  a  join numbers('number'="18880094567") as b on a.number = b.number; """
+                sql """ set parallel_pipeline_task_num = 1; """
+                sql """ select count(*)  from numbers("number" = "598318881") as  a  join numbers('number'="598318881") as b on a.number = b.number; """
             }catch(Exception e){
                 
             }
@@ -38,13 +39,13 @@ suite('test_manager_interface_5',"p0") {
 
         futures.add( thread {
             // test trace id in processlist
-            sleep(500);
+            sleep(5000);
             List<List<Object>> result = sql_return_maparray """  show processlist  """
             def queryid = ""
             def x = 0
             logger.info("result = ${result}")
             for( int i =0 ;i < result.size();i++ ){
-                if (result[i]["Info"].contains("18880094567")) {
+                if (result[i]["Info"].contains("598318881")) {
                     queryid = result[i]["QueryId"]
                     assertTrue(result[i]["TraceId"].equals("test_manager_interface_5_trace_id"))
                     x = 1
@@ -58,7 +59,7 @@ suite('test_manager_interface_5',"p0") {
             def x2 = 0
             logger.info("result = ${result}")
             for( int i =0 ;i < result.size();i++ ){
-                if (result[i]["Info"].contains("18880094567")) {
+                if (result[i]["Info"].contains("598318881")) {
                     queryid2 = result[i]["QueryId"]
                     assertTrue(result[i]["TraceId"].equals("test_manager_interface_5_trace_id"))
                     x2 = 1