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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to