You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by yi...@apache.org on 2024/02/22 11:52:32 UTC
(doris) 15/19: [fix](mtmv) fix mtmv workload group case failed (#31218)
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
commit a6c0be611cc77ced98c145ca7ba8f557be176d6d
Author: zhangdong <49...@qq.com>
AuthorDate: Thu Feb 22 17:56:21 2024 +0800
[fix](mtmv) fix mtmv workload group case failed (#31218)
---
.../src/main/groovy/org/apache/doris/regression/suite/Suite.groovy | 4 ++--
regression-test/suites/mtmv_p0/test_workload_group_mtmv.groovy | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy b/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy
index 7d8a388b5ee..27632326a3b 100644
--- a/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy
+++ b/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy
@@ -919,7 +919,7 @@ class Suite implements GroovyInterceptable {
void waitingMTMVTaskFinished(String jobName) {
Thread.sleep(2000);
- String showTasks = "select TaskId,JobId,JobName,MvId,Status from tasks('type'='mv') where JobName = '${jobName}' order by CreateTime ASC"
+ String showTasks = "select TaskId,JobId,JobName,MvId,Status,MvName,MvDatabaseName,ErrorMsg from tasks('type'='mv') where JobName = '${jobName}' order by CreateTime ASC"
String status = "NULL"
List<List<Object>> result
long startTime = System.currentTimeMillis()
@@ -941,7 +941,7 @@ class Suite implements GroovyInterceptable {
void waitingMTMVTaskFinishedNotNeedSuccess(String jobName) {
Thread.sleep(2000);
- String showTasks = "select TaskId,JobId,JobName,MvId,Status from tasks('type'='mv') where JobName = '${jobName}' order by CreateTime ASC"
+ String showTasks = "select TaskId,JobId,JobName,MvId,Status,MvName,MvDatabaseName,ErrorMsg from tasks('type'='mv') where JobName = '${jobName}' order by CreateTime ASC"
String status = "NULL"
List<List<Object>> result
long startTime = System.currentTimeMillis()
diff --git a/regression-test/suites/mtmv_p0/test_workload_group_mtmv.groovy b/regression-test/suites/mtmv_p0/test_workload_group_mtmv.groovy
index d08ff938f28..4e95f6c258d 100644
--- a/regression-test/suites/mtmv_p0/test_workload_group_mtmv.groovy
+++ b/regression-test/suites/mtmv_p0/test_workload_group_mtmv.groovy
@@ -53,7 +53,7 @@ suite("test_workload_group_mtmv") {
sql """
refresh MATERIALIZED VIEW ${mvName};
"""
- jobName = getJobName(dbName, mvName);
+ def jobName = getJobName(dbName, mvName);
logger.info(jobName)
waitingMTMVTaskFinishedNotNeedSuccess(jobName)
def errors = sql """select ErrorMsg from tasks('type'='mv') where MvName='${mvName}' and MvDatabaseName='${dbName}';"""
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org