database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[regression-test](fix) fix workload_manager_p0 case bug (#47100)

Browse Source
This commit is contained in:
shuke
2025-01-16 21:11:38 +08:00
committed by GitHub
parent 171251cf42
commit 9decc111e0
1 changed files with 0 additions and 51 deletions
Download Patch File Download Diff File Expand all files Collapse all files

51
regression-test/suites/workload_manager_p0/test_workload_sched_policy.groovy
View File

@ -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()
}