This is an automated email from the ASF dual-hosted git repository.
gavinchou pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 016cb20158f [regression-test](fix) remove unused code in
test_workload_sched_policy (#47344)
016cb20158f is described below
commit 016cb20158fd1594df5350c18b21edbd9d70e072
Author: shuke <sh...@selectdb.com>
AuthorDate: Thu Jan 23 14:29:02 2025 +0800
[regression-test](fix) remove unused code in test_workload_sched_policy
(#47344)
---
.../test_workload_sched_policy.groovy | 57 ----------------------
1 file changed, 57 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 06e10688397..ca18c5a17e0 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
@@ -235,61 +235,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 as
policy_test_tag,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) {
- boolean ret = e.getMessage().contains("cancelled by
workload policy")
- if (!ret) {
- logger.info("policy_test_tag " + e.getMessage())
- }
- assertTrue(ret, "policy daemon check failed")
- }
-
- try {
- sql "select count(1) as policy_test_tag from
regression_test_load_p0_insert.baseall"
- } catch (Exception e) {
- boolean ret = e.getMessage().contains("cancelled by
workload policy")
- if (!ret) {
- logger.info("policy_test_tag " + e.getMessage())
- }
- assertTrue(ret, "policy daemon check failed")
- }
-
- Thread.sleep(1000)
- curTime = System.currentTimeMillis()
- }
- }
- })
- thread1.setDaemon(true)
- thread1.start()
-
}
\ No newline at end of file
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
