From 9decc111e0747ece88a42fa2f6ff7702cbca1d56 Mon Sep 17 00:00:00 2001 From: shuke Date: Thu, 16 Jan 2025 21:11:38 +0800 Subject: [PATCH] [regression-test](fix) fix workload_manager_p0 case bug (#47100) --- .../test_workload_sched_policy.groovy | 51 ------------------- 1 file changed, 51 deletions(-) diff --git a/regression-test/suites/workload_manager_p0/test_workload_sched_policy.groovy b/regression-test/suites/workload_manager_p0/test_workload_sched_policy.groovy index b60d8c4629..ae82f2d8ea 100644 --- a/regression-test/suites/workload_manager_p0/test_workload_sched_policy.groovy +++ b/regression-test/suites/workload_manager_p0/test_workload_sched_policy.groovy @@ -238,55 +238,4 @@ suite("test_workload_sched_policy") { sql "drop user test_alter_policy_user" sql "drop workload policy test_alter_policy" - - // daemon thread alter test - def thread1 = new Thread({ - def startTime = System.currentTimeMillis() - def curTime = System.currentTimeMillis() - def totalTime = 30 * 60 * 1000 // 30min - - connect('test_policy_user', '12345', context.config.jdbcUrl) { - sql "set workload_group=policy_group" - boolean flag = false - long lastTime = System.currentTimeMillis() - - while (curTime - startTime <= totalTime) { - if (curTime - lastTime > 20000) { - if (flag) { - connect('root', '', context.config.jdbcUrl) { - sql "alter workload policy test_cancel_query_policy properties('workload_group'='policy_group2');" - sql "alter workload policy test_cancel_query_policy2 properties('workload_group'='policy_group');" - } - flag = false - } else { - connect('root', '', context.config.jdbcUrl) { - sql "alter workload policy test_cancel_query_policy properties('workload_group'='policy_group');" - sql "alter workload policy test_cancel_query_policy2 properties('workload_group'='policy_group2');" - } - flag = true - } - lastTime = System.currentTimeMillis() - } - try { - sql "select k0,k1,k2,k3,k4,k5,k6,count(distinct k13) from regression_test_load_p0_insert.baseall group by k0,k1,k2,k3,k4,k5,k6" - } catch (Exception e) { - logger.info("exception: ${e.getMessage()}") - assertTrue(e.getMessage().contains("query canceled by workload scheduler")) - } - - try { - sql "select count(1) from regression_test_load_p0_insert.baseall" - } catch (Exception e) { - logger.info("exception: ${e.getMessage()}") - assertTrue(e.getMessage().contains("query canceled by workload scheduler")) - } - - Thread.sleep(1000) - curTime = System.currentTimeMillis() - } - } - }) - thread1.setDaemon(true) - thread1.start() - } \ No newline at end of file